Fix reading after sync at EOF

artem-garmash · Feb 5, 2016 · d932b16 · d932b16
1 parent 76d3d81
commit d932b16
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/python-hadoop/hadoop/io/SequenceFile.py b/python-hadoop/hadoop/io/SequenceFile.py
@@ -353,6 +353,9 @@ def nextRawKey(self):
                 raise IOError("File is corrupt")
             self._sync_seen = True
 
+            if self._stream.getPos() >= self._end:
+                return None
+
             def _readBuffer():
                 length = readVInt(self._stream)
                 buf = self._stream.read(length)