diff --git a/src/server/cluster/Cluster.go b/src/server/cluster/Cluster.go
index 0a9e5efa..93a2004d 100644
--- a/src/server/cluster/Cluster.go
+++ b/src/server/cluster/Cluster.go
@@ -96,7 +96,7 @@ func (a *Agent) Run() {
 		err = GoUtil.GobUnmarshal(data, &m)
 		if err != nil {
 			log.Debug("decode err: %v", err)
-			return
+			continue
 		}
 		err = processMsg(a, &m)
 		if err != nil {