Repository: carbondata Updated Branches: refs/heads/master d1bfb7477 -> 817230da1
[CARBONDATA-2955] Fix bugs in adaptive delta integral codec with compressor This closes #2741 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/817230da Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/817230da Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/817230da Branch: refs/heads/master Commit: 817230da112684e057aa808711d44c305692d45f Parents: d1bfb74 Author: xuchuanyin <[email protected]> Authored: Fri Sep 21 09:25:36 2018 +0800 Committer: Jacky Li <[email protected]> Committed: Fri Sep 21 15:45:03 2018 +0800 ---------------------------------------------------------------------- .../page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/817230da/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java b/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java index 9ada0bb..0e61b33 100644 --- a/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java +++ b/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java @@ -79,12 +79,13 @@ public class AdaptiveDeltaIntegralCodec extends AdaptiveCodec { public ColumnPageEncoder createEncoder(Map<String, String> parameter) { return new ColumnPageEncoder() { byte[] result = null; - final Compressor compressor = CompressorFactory.getInstance().getCompressor(); @Override protected byte[] encodeData(ColumnPage input) throws MemoryException, IOException { if (encodedPage != null) { throw new IllegalStateException("already encoded"); } + Compressor compressor = + CompressorFactory.getInstance().getCompressor(input.getColumnCompressorName()); result = encodeAndCompressPage(input, converter, compressor); byte[] bytes = writeInvertedIndexIfRequired(result); encodedPage.freeMemory();
