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);

Reply via email to