Permalink
Browse files

Changed an incorrect status output and bumpped up the server socket b…

…uffer size to 10m
  • Loading branch information...
1 parent 6448e71 commit b5f56e5f074502d5541dc2b5aff048136495bbac Lei Gao committed Oct 11, 2011
@@ -21,8 +21,8 @@
import java.util.Iterator;
import java.util.List;
import java.util.Map;
-import java.util.Set;
import java.util.Map.Entry;
+import java.util.Set;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.SynchronousQueue;
@@ -201,7 +201,7 @@ private String getHeader(List<RebalancePartitionsInfo> stealInfos) {
for(RebalancePartitionsInfo info: stealInfos) {
stealerNodeIds.add(info.getStealerId());
}
- return " Donor " + stealInfos.get(0).getDonorId() + ", Donor " + stealerNodeIds + "] ";
+ return " Donor " + stealInfos.get(0).getDonorId() + ", Stealer " + stealerNodeIds + "] ";
}
/**
@@ -2,6 +2,7 @@
node.id=0
max.threads=100
+socket.buffer.size=10000000
############### DB options ######################
@@ -2,6 +2,7 @@
node.id=1
max.threads=100
+socket.buffer.size=10000000
############### DB options ######################
@@ -2,6 +2,7 @@
node.id=2
max.threads=100
+socket.buffer.size=10000000
############### DB options ######################
@@ -2,6 +2,7 @@
node.id=3
max.threads=100
+socket.buffer.size=10000000
############### DB options ######################
@@ -2,6 +2,7 @@
node.id=4
max.threads=100
+socket.buffer.size=10000000
############### DB options ######################
@@ -2,6 +2,7 @@
node.id=5
max.threads=100
+socket.buffer.size=10000000
############### DB options ######################

0 comments on commit b5f56e5

Please sign in to comment.