You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by qh...@apache.org on 2015/05/28 12:48:29 UTC
incubator-kylin git commit: fix
Repository: incubator-kylin
Updated Branches:
refs/heads/streaming-cubing 7717e6edc -> 838c8717e
fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/838c8717
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/838c8717
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/838c8717
Branch: refs/heads/streaming-cubing
Commit: 838c8717ea7ad1e6ceb07b7d554ad46e2c527159
Parents: 7717e6e
Author: qianhao.zhou <qi...@ebay.com>
Authored: Thu May 28 18:48:24 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Thu May 28 18:48:24 2015 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/kylin/streaming/StreamBuilder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/838c8717/streaming/src/main/java/org/apache/kylin/streaming/StreamBuilder.java
----------------------------------------------------------------------
diff --git a/streaming/src/main/java/org/apache/kylin/streaming/StreamBuilder.java b/streaming/src/main/java/org/apache/kylin/streaming/StreamBuilder.java
index a25dce3..14a9e28 100644
--- a/streaming/src/main/java/org/apache/kylin/streaming/StreamBuilder.java
+++ b/streaming/src/main/java/org/apache/kylin/streaming/StreamBuilder.java
@@ -79,7 +79,7 @@ public abstract class StreamBuilder implements Runnable {
logger.warn("stream queue interrupted", e);
continue;
}
- if (streamMessage == null) {
+ if (streamMessage == null || getStreamParser().parse(streamMessage) == null) {
logger.info("The stream queue is drained, current available stream count: " + streamMessageToBuild.size());
if ((System.currentTimeMillis() - lastBuildTime) > batchInterval()) {