Revert "KYLIN-1270" This reverts commit d3648849626c78b1e44df4050a620c25e5ee805f.
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/1dc361c6 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/1dc361c6 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/1dc361c6 Branch: refs/heads/2.0-rc Commit: 1dc361c6d30d1b01e0bf2c3677f6a6d90f670396 Parents: ea702c8 Author: honma <ho...@ebay.com> Authored: Tue Jan 5 16:10:45 2016 +0800 Committer: honma <ho...@ebay.com> Committed: Wed Jan 6 10:05:29 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/source/kafka/TimedJsonStreamParser.java | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/1dc361c6/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 f7f15ab..0907623 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 @@ -36,7 +36,6 @@ package org.apache.kylin.source.kafka; import java.io.IOException; import java.util.ArrayList; -import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.List; @@ -109,10 +108,8 @@ public final class TimedJsonStreamParser extends StreamingParser { //" cannot be null, the message offset is " + messageAndOffset.getOffset() + " content is " + new String(messageAndOffset.getRawData())); long t; if (StringUtils.isEmpty(tsStr)) { - logger.info("tsStr not found"); t = 0; } else { - logger.info("tsStr is :" + tsStr); t = Long.valueOf(tsStr); } ArrayList<String> result = Lists.newArrayList(); @@ -148,8 +145,6 @@ public final class TimedJsonStreamParser extends StreamingParser { } } - logger.info(Arrays.toString(result.toArray())); - return new StreamingMessage(result, messageAndOffset.offset(), t, Collections.<String, Object> emptyMap()); } catch (IOException e) {
