This is an automated email from the ASF dual-hosted git repository. nic pushed a commit to branch 3.0.x in repository https://gitbox.apache.org/repos/asf/kylin.git
commit b8c5252cb15e9f1aa685a6387b7ba15378b1bd5a Author: zengruios <[email protected]> AuthorDate: Mon Dec 16 22:19:33 2019 +0800 fix bug in KYLIN-4243 --- .../kylin/stream/core/storage/columnar/ColumnarStoreDimDesc.java | 5 +++-- .../stream/core/storage/columnar/ColumnarStoreMetricsDesc.java | 6 ++++-- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreDimDesc.java b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreDimDesc.java index 0406ecb..971d137 100644 --- a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreDimDesc.java +++ b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreDimDesc.java @@ -78,7 +78,7 @@ public class ColumnarStoreDimDesc { } else if (compression == Compression.RUN_LENGTH) { return new RunLengthCompressedColumnReader(dataBuffer, columnDataStartOffset, columnDataLength, rowCount); } - return new NoCompressedColumnReader(dataBuffer, columnDataStartOffset, columnDataLength, rowCount); + return new NoCompressedColumnReader(dataBuffer, columnDataStartOffset, columnDataLength / rowCount, rowCount); } public ColumnDataReader getDimReaderFromFSInput(FSDataInputStream inputStream, int columnDataStartOffset, @@ -88,6 +88,7 @@ public class ColumnarStoreDimDesc { } else if (compression == Compression.RUN_LENGTH) { return new FSInputRLECompressedColumnReader(inputStream, columnDataStartOffset, columnDataLength, rowCount); } - return new FSInputNoCompressedColumnReader(inputStream, columnDataStartOffset, columnDataLength, rowCount); + return new FSInputNoCompressedColumnReader(inputStream, columnDataStartOffset, columnDataLength / rowCount, + rowCount); } } diff --git a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreMetricsDesc.java b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreMetricsDesc.java index 098134d..eca5ae7 100644 --- a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreMetricsDesc.java +++ b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ColumnarStoreMetricsDesc.java @@ -68,7 +68,8 @@ public class ColumnarStoreMetricsDesc { return new LZ4CompressedColumnReader(dataBuffer, columnDataStartOffset, columnDataLength, rowCount); } if (fixLen != -1) { - return new NoCompressedColumnReader(dataBuffer, columnDataStartOffset, columnDataLength, rowCount); + return new NoCompressedColumnReader(dataBuffer, columnDataStartOffset, columnDataLength / rowCount, + rowCount); } return new GeneralColumnDataReader(dataBuffer, columnDataStartOffset, columnDataLength); } @@ -79,7 +80,8 @@ public class ColumnarStoreMetricsDesc { return new FSInputLZ4CompressedColumnReader(inputStream, columnDataStartOffset, columnDataLength, rowCount); } if (fixLen != -1) { - return new FSInputNoCompressedColumnReader(inputStream, columnDataStartOffset, columnDataLength, rowCount); + return new FSInputNoCompressedColumnReader(inputStream, columnDataStartOffset, columnDataLength / rowCount, + rowCount); } return new FSInputGeneralColumnDataReader(inputStream, columnDataStartOffset, columnDataLength); }
