hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject hama git commit: Quick fix for streaming
Date Tue, 24 Nov 2015 06:53:04 GMT
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 <edwardyoon@apache.org>
Authored: Tue Nov 24 15:52:36 2015 +0900
Committer: Edward J. Yoon <edwardyoon@apache.org>
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();


Mime
View raw message