Repository: hama Updated Branches: refs/heads/master e488e08d1 -> c095c7da2
Quick fix for streaming Project: http://git-wip-us.apache.org/repos/asf/hama/repo Commit: http://git-wip-us.apache.org/repos/asf/hama/commit/c095c7da Tree: http://git-wip-us.apache.org/repos/asf/hama/tree/c095c7da Diff: http://git-wip-us.apache.org/repos/asf/hama/diff/c095c7da Branch: refs/heads/master Commit: c095c7da2e529256579429da9bb2d534a96da873 Parents: e488e08 Author: Edward J. Yoon <[email protected]> Authored: Tue Nov 24 15:52:36 2015 +0900 Committer: Edward J. Yoon <[email protected]> Committed: Tue Nov 24 15:52:36 2015 +0900 ---------------------------------------------------------------------- .../main/java/org/apache/hama/pipes/protocol/UplinkReader.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hama/blob/c095c7da/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 @@ public class UplinkReader<KEYIN, VALUEIN, KEYOUT, VALUEOUT, M extends Writable> // 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();
