Github user QiangCai commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2628#discussion_r213942049
--- 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 --
SupportedCompressor.SNAPPY.getName
---
