diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java index d7be74a..778e853 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java @@ -1506,8 +1506,8 @@ public class RpcServer implements RpcServerInterface { if (!headerRead) { continue; } - } else { - // More to read still; go around again. + } else if (count > 0) { + // We got some data and there is more to read still; go around again. if (LOG.isTraceEnabled()) LOG.trace("Continue to read rest of data " + data.remaining()); continue; }