test/dataflow
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

更新proto

Browse Source
This commit is contained in:
huangsimin
2022-08-12 18:01:46 +08:00
parent 5530f935d4
commit f8a2a5aee8
2 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/yuandian/dataflow/controller/MasterProcessor.java
View File

@@ -65,9 +65,7 @@ public class MasterProcessor implements MasterExecute {
var peers = new ArrayList<Peer>(); var peers = new ArrayList<Peer>();
while (iter.hasNext()) { while (iter.hasNext()) {
var curPeer = iter.next(); var curPeer = iter.next();
if (packetsManager.size() >= 100000) { if (packetsManager.size() >= 100000) {

2
src/main/proto

Submodule src/main/proto updated: bc997440f0...5ef843db43