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..eda41b8 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 @@ -63,10 +63,9 @@ public abstract class BaseDecoder implements Codec.Decoder { LOG.trace("Error getting available for error message - ignoring", t); } if (!isEof) throw ioEx; + // if EOFException is thrown, HLogSplitter would continue with the WAL - leading to data loss LOG.error("Partial cell read caused by EOF: " + ioEx); - EOFException eofEx = new EOFException("Partial cell read"); - eofEx.initCause(ioEx); - throw eofEx; + throw ioEx; } /**