fix dict read bug

edms · Apr 14, 2021 · e2758ab · e2758ab
1 parent 521bf34
commit e2758ab
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/layout/page.go b/layout/page.go
@@ -776,10 +776,15 @@ func ReadPage(thriftReader *thrift.TBufferedTransport, schemaHandler *schema.Sch
 		page.Header = pageHeader
 		table := new(Table)
 		table.Path = path
+		bitWidth, idx := 0, schemaHandler.MapIndex[name]
+		if colMetaData.GetType() == parquet.Type_FIXED_LEN_BYTE_ARRAY {
+			bitWidth = int(schemaHandler.SchemaElements[idx].GetTypeLength())
+		}
+
 		table.Values, err = encoding.ReadPlain(bytesReader,
 			colMetaData.GetType(),
 			uint64(pageHeader.DictionaryPageHeader.GetNumValues()),
-			0)
+			uint64(bitWidth))
 		if err != nil {
 			return nil, 0, 0, err
 		}