BigDecimal and VariableLength Dimension fixes
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/92352f3a Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/92352f3a Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/92352f3a Branch: refs/heads/branch-1.1 Commit: 92352f3a695e99702564287921b57e72aa7f3a07 Parents: f58853d Author: vpp9380 <vpp9...@gmail.com> Authored: Sat Apr 15 17:01:48 2017 +0530 Committer: Venkata Ramana G <ramana.gollam...@huawei.com> Committed: Sat Apr 15 22:04:01 2017 +0530 ---------------------------------------------------------------------- .../store/impl/unsafe/UnsafeBigDecimalMeasureChunkStore.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/92352f3a/core/src/main/java/org/apache/carbondata/core/datastore/chunk/store/impl/unsafe/UnsafeBigDecimalMeasureChunkStore.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/datastore/chunk/store/impl/unsafe/UnsafeBigDecimalMeasureChunkStore.java b/core/src/main/java/org/apache/carbondata/core/datastore/chunk/store/impl/unsafe/UnsafeBigDecimalMeasureChunkStore.java index 52bd74b..4082689 100644 --- a/core/src/main/java/org/apache/carbondata/core/datastore/chunk/store/impl/unsafe/UnsafeBigDecimalMeasureChunkStore.java +++ b/core/src/main/java/org/apache/carbondata/core/datastore/chunk/store/impl/unsafe/UnsafeBigDecimalMeasureChunkStore.java @@ -124,11 +124,10 @@ public class UnsafeBigDecimalMeasureChunkStore extends UnsafeAbstractMeasureData int OffsetOfNextdata = CarbonUnsafe.unsafe.getInt(dataPageMemoryBlock.getBaseObject(), dataPageMemoryBlock.getBaseOffset() + this.offsetStartPosition + ((index + 1) * CarbonCommonConstants.INT_SIZE_IN_BYTE)); - length = - (short) (OffsetOfNextdata - (currentDataOffset + CarbonCommonConstants.INT_SIZE_IN_BYTE)); + length = OffsetOfNextdata - (currentDataOffset + CarbonCommonConstants.INT_SIZE_IN_BYTE); } else { // for last record we need to subtract with data length - length = (short) (this.offsetStartPosition - currentDataOffset); + length = (int) this.offsetStartPosition - currentDataOffset; } byte[] row = new byte[length]; CarbonUnsafe.unsafe.copyMemory(dataPageMemoryBlock.getBaseObject(),
