diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/codec/BaseDecoder.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/codec/BaseDecoder.java index 281340b..4693bd3 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/codec/BaseDecoder.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/codec/BaseDecoder.java @@ -43,10 +43,6 @@ public abstract class BaseDecoder implements Codec.Decoder { @Override public boolean advance() throws IOException { if (!this.hasNext) return this.hasNext; - if (this.in.available() == 0) { - this.hasNext = false; - return this.hasNext; - } try { this.current = parseCell(); } catch (IOException ioEx) {