Repository: kylin Updated Branches: refs/heads/master 9ebc741d8 -> c9dcb07c7
KYLIN-1726 debugging messages Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c9dcb07c Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c9dcb07c Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c9dcb07c Branch: refs/heads/master Commit: c9dcb07c72d0fef99ce8f630936b819c2db73408 Parents: 9ebc741 Author: Hongbin Ma <mahong...@apache.org> Authored: Mon Sep 19 22:11:59 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Mon Sep 19 22:13:13 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/source/kafka/TimedJsonStreamParser.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/c9dcb07c/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java index 7db8285..ab8b161 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java @@ -18,14 +18,15 @@ package org.apache.kylin.source.kafka; import java.io.IOException; +import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.TreeMap; + import org.apache.commons.lang3.StringUtils; -import java.nio.ByteBuffer; import org.apache.kylin.common.util.StreamingMessage; import org.apache.kylin.metadata.model.TblColRef; import org.slf4j.Logger; @@ -103,7 +104,8 @@ public final class TimedJsonStreamParser extends StreamingParser { } } - return new StreamingMessage(result, 0, t, Collections.<String, Object>emptyMap()); + logger.info("Streaming Message: " + result.toString()); + return new StreamingMessage(result, 0, t, Collections.<String, Object> emptyMap()); } catch (IOException e) { logger.error("error", e); throw new RuntimeException(e);
