Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2628#discussion_r214560605
--- Diff:
core/src/main/java/org/apache/carbondata/core/util/BlockletDataMapUtil.java ---
@@ -357,8 +357,8 @@ private static boolean
isSameColumnSchemaList(List<ColumnSchema> indexFileColumn
columnSchema.write(dataOutput);
}
byte[] byteArray = stream.toByteArray();
- // Compress with snappy to reduce the size of schema
- return
CompressorFactory.getInstance().getCompressor().compressByte(byteArray);
+ // Compress to reduce the size of schema
+ return
CompressorFactory.getInstance().getCompressor("snappy").compressByte(byteArray);
--- End diff --
OK~
---
