Repository: kylin Updated Branches: refs/heads/2.0-rc f18f7b025 -> 924421810
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/92442181 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/92442181 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/92442181 Branch: refs/heads/2.0-rc Commit: 9244218103906566d50bb1eb17e6dbd8da2eee6e Parents: 1f93bec Author: yangzhong <yangzh...@ebay.com> Authored: Tue Feb 23 18:01:17 2016 +0800 Committer: honma <ho...@ebay.com> Committed: Tue Feb 23 18:22:08 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/92442181/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);
