You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2016/02/23 12:09:08 UTC
[2/4] kylin git commit: KYLIN-1436: If error exists during fetching
streaming messages, streaming building should throw exception
KYLIN-1436: If error exists during fetching streaming messages, streaming building should throw exception
Signed-off-by: honma <ho...@ebay.com>
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/28321936
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/28321936
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/28321936
Branch: refs/heads/2.x-staging
Commit: 28321936b2b72cefdf034c4919fcecd0c1a3079a
Parents: 87cc509
Author: yangzhong <ya...@ebay.com>
Authored: Tue Feb 23 18:01:17 2016 +0800
Committer: honma <ho...@ebay.com>
Committed: Tue Feb 23 18:26:35 2016 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/source/kafka/KafkaStreamingInput.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/28321936/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaStreamingInput.java
----------------------------------------------------------------------
diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaStreamingInput.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaStreamingInput.java
index bcde47b..2e262b3 100644
--- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaStreamingInput.java
+++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaStreamingInput.java
@@ -90,8 +90,7 @@ public class KafkaStreamingInput implements IStreamingInput {
logger.warn("this thread should not be interrupted, just ignore", e);
continue;
} catch (ExecutionException e) {
- logger.error("error when get StreamingMessages", e.getCause());
- continue;
+ throw new RuntimeException("error when get StreamingMessages",e.getCause());
}
}
final Pair<Long, Long> timeRange = Pair.newPair(startTime, endTime);