diff --git a/src/main/java/com/yuandian/dataflow/controller/MasterProcessor.java b/src/main/java/com/yuandian/dataflow/controller/MasterProcessor.java index 2848928..53c8705 100644 --- a/src/main/java/com/yuandian/dataflow/controller/MasterProcessor.java +++ b/src/main/java/com/yuandian/dataflow/controller/MasterProcessor.java @@ -65,9 +65,7 @@ public class MasterProcessor implements MasterExecute { var peers = new ArrayList(); while (iter.hasNext()) { - - - + var curPeer = iter.next(); if (packetsManager.size() >= 100000) { diff --git a/src/main/proto b/src/main/proto index bc99744..5ef843d 160000 --- a/src/main/proto +++ b/src/main/proto @@ -1 +1 @@ -Subproject commit bc997440f085ce75fadc071803b0b359bbf6ccb3 +Subproject commit 5ef843db43a21976ac1f03eea954ac9cc72015f8