Avoid EndOfStreamException (#95)

ishepherd · aloneguid · web-flow · commit 88f37d2e78a6 · 2021-02-28T15:28:03.000Z
Co-authored-by: Ivan Gavryliuk &lt;aloneguid@outlook.com&gt;
diff --git a/src/Parquet/File/DataColumnReader.cs b/src/Parquet/File/DataColumnReader.cs
@@ -277,7 +277,11 @@ private static int ReadPlainDictionary(BinaryReader reader, int maxReadCount, in
          }
          else
          {
-            offset += RunLengthBitPackingHybridValuesReader.ReadRleBitpackedHybrid(reader, bitWidth, length, dest, offset, maxReadCount);
+            int length = GetRemainingLength(reader);
+            if (length != 0)
+            {
+               offset += RunLengthBitPackingHybridValuesReader.ReadRleBitpackedHybrid(reader, bitWidth, length, dest, offset, maxReadCount);
+            }
          }
 
          return offset - start;

Original file line number	Diff line number	Diff line change
`@@ -277,7 +277,11 @@ private static int ReadPlainDictionary(BinaryReader reader, int maxReadCount, in`
`277`	`277`	`}`
`278`	`278`	`else`
`279`	`279`	`{`
`280`		`- offset += RunLengthBitPackingHybridValuesReader.ReadRleBitpackedHybrid(reader, bitWidth, length, dest, offset, maxReadCount);`
	`280`	`+ int length = GetRemainingLength(reader);`
	`281`	`+ if (length != 0)`
	`282`	`+ {`
	`283`	`+ offset += RunLengthBitPackingHybridValuesReader.ReadRleBitpackedHybrid(reader, bitWidth, length, dest, offset, maxReadCount);`
	`284`	`+ }`
`281`	`285`	`}`
`282`	`286`
`283`	`287`	`return offset - start;`