This is an automated email from the ASF dual-hosted git repository. magang pushed a commit to branch realtime-streaming in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/realtime-streaming by this push: new 99c8883 KYLIN-3800 Measure get incorrect result 99c8883 is described below commit 99c88831595cbfad1728ecdfa3a0faecf1ee7a64 Author: chao long <wayn...@qq.com> AuthorDate: Thu Jan 31 17:40:03 2019 +0800 KYLIN-3800 Measure get incorrect result --- .../kylin/stream/core/storage/columnar/ParsedStreamingCubeInfo.java | 6 ++++++ .../kylin/stream/core/storage/columnar/SegmentMemoryStore.java | 1 + 2 files changed, 7 insertions(+) diff --git a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ParsedStreamingCubeInfo.java b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ParsedStreamingCubeInfo.java index 503278a..c730d0d 100644 --- a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ParsedStreamingCubeInfo.java +++ b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/ParsedStreamingCubeInfo.java @@ -254,4 +254,10 @@ public class ParsedStreamingCubeInfo { return (int) (cuboidID ^ (cuboidID >>> 32)); } } + + public void resetAggrs() { + for (int i = 0; i < cubeDesc.getMeasures().size(); i++) { + measureIngesters[i].reset(); + } + } } diff --git a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/SegmentMemoryStore.java b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/SegmentMemoryStore.java index 6fff1c6..1b0bb6a 100644 --- a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/SegmentMemoryStore.java +++ b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/columnar/SegmentMemoryStore.java @@ -96,6 +96,7 @@ public class SegmentMemoryStore implements IStreamingGTSearcher { maxEventTime = eventTime; } List<String> row = event.getData(); + parsedStreamingCubeInfo.resetAggrs(); String[] basicCuboidDimensions = buildBasicCuboidKey(row); Object[] metricsValues = buildValue(row); aggregate(basicCuboidAggBufMap, basicCuboidDimensions, metricsValues);