You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by jn...@apache.org on 2026/03/28 06:28:35 UTC
(storm) 01/01: bugfix sequencefilereader
This is an automated email from the ASF dual-hosted git repository.
jnioche pushed a commit to branch bugSequenceFileReader
in repository https://gitbox.apache.org/repos/asf/storm.git
commit 1eafcafba537ea4c48520b431867f9c5642d3576
Author: Julien Nioche <ju...@digitalpebble.com>
AuthorDate: Sat Mar 28 06:28:16 2026 +0000
bugfix sequencefilereader
Signed-off-by: Julien Nioche <ju...@digitalpebble.com>
---
.../src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 d245df7ea..cf9dc1767 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 @@ public class SequenceFileReader<KeyT extends Writable, ValueT extends Writable>
}
++currentRecord;
prevRecordEndOffset = currRecordEndOffset;
- currentRecord = newBytePosition;
+ currRecordEndOffset = newBytePosition;
}
@Override