kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nju_y...@apache.org
Subject [07/50] kylin git commit: KYLIN-1421 Cube "source record" is always zero for streaming
Date Mon, 18 Apr 2016 06:34:49 GMT
KYLIN-1421 Cube "source record" is always zero for streaming

Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/533c4f0e
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/533c4f0e
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/533c4f0e

Branch: refs/heads/1.4-rc
Commit: 533c4f0e65db8276a04e2c82bd4478f2ec41c996
Parents: 3c390de
Author: shaofengshi <shaofengshi@apache.org>
Authored: Tue Feb 16 10:30:05 2016 +0800
Committer: shaofengshi <shaofengshi@apache.org>
Committed: Tue Feb 16 10:30:05 2016 +0800

----------------------------------------------------------------------
 .../apache/kylin/engine/streaming/cube/StreamingCubeBuilder.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/533c4f0e/engine-streaming/src/main/java/org/apache/kylin/engine/streaming/cube/StreamingCubeBuilder.java
----------------------------------------------------------------------
diff --git a/engine-streaming/src/main/java/org/apache/kylin/engine/streaming/cube/StreamingCubeBuilder.java
b/engine-streaming/src/main/java/org/apache/kylin/engine/streaming/cube/StreamingCubeBuilder.java
index e285ee8..deb3673 100644
--- a/engine-streaming/src/main/java/org/apache/kylin/engine/streaming/cube/StreamingCubeBuilder.java
+++ b/engine-streaming/src/main/java/org/apache/kylin/engine/streaming/cube/StreamingCubeBuilder.java
@@ -116,6 +116,7 @@ public class StreamingCubeBuilder implements StreamingBatchBuilder {
         try {
             CubeSegment segment = cubeManager.appendSegments(cubeInstance, streamingBatch.getTimeRange().getFirst(),
streamingBatch.getTimeRange().getSecond(), false, false);
             segment.setLastBuildJobID(segment.getUuid()); // give a fake job id
+            segment.setInputRecords(streamingBatch.getMessages().size());
             return segment;
         } catch (IOException e) {
             throw new RuntimeException("failed to create IBuildable", e);


Mime
View raw message