diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java
index d245df7eaa8..cf9dc1767b6 100644
--- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java
+++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java
@@ -201,7 +201,7 @@ void increment(boolean syncSeen, long newBytePosition) {
             }
             ++currentRecord;
             prevRecordEndOffset = currRecordEndOffset;
-            currentRecord = newBytePosition;
+            currRecordEndOffset = newBytePosition;
         }
 
         @Override