KYLIN-1421 fix the “Last build time” is always empty issue

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

Branch: refs/heads/helix-rebase
Commit: 7edc8b892ae9f955fc27cd9f047049a56ab41651
Parents: 0ff0e6d
Author: shaofengshi <[email protected]>
Authored: Tue Feb 16 14:07:00 2016 +0800
Committer: shaofengshi <[email protected]>
Committed: Fri Mar 4 09:52:20 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/7edc8b89/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 d373e4a..4b11408 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
@@ -117,6 +117,7 @@ public class StreamingCubeBuilder implements 
StreamingBatchBuilder {
             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());
+            segment.setLastBuildTime(System.currentTimeMillis());
             return segment;
         } catch (IOException e) {
             throw new RuntimeException("failed to create IBuildable", e);

Reply via email to