commit c095c7da2e529256579429da9bb2d534a96da873
author Edward J. Yoon <edwardyoon@apache.org> Tue Nov 24 15:52:36 2015 +0900
committer Edward J. Yoon <edwardyoon@apache.org> Tue Nov 24 15:52:36 2015 +0900
tree 09ce6934a336f69fe97a7994f732a393279bb926
parent e488e08d18c6ce16840a0c843f8eb9c2161dfb1e

Quick fix for streaming

core/src/main/java/org/apache/hama/pipes/protocol/UplinkReader.java

diff --git a/core/src/main/java/org/apache/hama/pipes/protocol/UplinkReader.java b/core/src/main/java/org/apache/hama/pipes/protocol/UplinkReader.java
index b91e698..a27ffe3 100644
--- a/core/src/main/java/org/apache/hama/pipes/protocol/UplinkReader.java
+++ b/core/src/main/java/org/apache/hama/pipes/protocol/UplinkReader.java
@@ -108,7 +108,9 @@
         // MessageType.values()[cmd] may cause NullPointerException (bad
         // command)
 
-        if (cmd == MessageType.WRITE_KEYVALUE.code && isPeerAvailable()) { // INCOMING
+        if (cmd == -1) {
+          continue;
+        } else if (cmd == MessageType.WRITE_KEYVALUE.code && isPeerAvailable()) { // INCOMING
           writeKeyValue();
         } else if (cmd == MessageType.READ_KEYVALUE.code && isPeerAvailable()) { // OUTGOING
           readKeyValue();