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 <shaofeng...@apache.org> Authored: Tue Feb 16 10:30:05 2016 +0800 Committer: shaofengshi <shaofeng...@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);
