You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2019/11/16 00:45:41 UTC
[kylin] branch master updated: KYLIN-4246 Fix for null value and
non-exist value in json parser.
This is an automated email from the ASF dual-hosted git repository.
nic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/master by this push:
new 6b853ce KYLIN-4246 Fix for null value and non-exist value in json parser.
6b853ce is described below
commit 6b853ceda852c92c4b3e884426be6b34e3c62e0d
Author: XiaoxiangYu <hi...@126.com>
AuthorDate: Sat Nov 16 03:45:56 2019 +0800
KYLIN-4246 Fix for null value and non-exist value in json parser.
---
.../org/apache/kylin/stream/source/kafka/TimedJsonStreamParser.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/stream-source-kafka/src/main/java/org/apache/kylin/stream/source/kafka/TimedJsonStreamParser.java b/stream-source-kafka/src/main/java/org/apache/kylin/stream/source/kafka/TimedJsonStreamParser.java
index 809844c..9617d8c 100644
--- a/stream-source-kafka/src/main/java/org/apache/kylin/stream/source/kafka/TimedJsonStreamParser.java
+++ b/stream-source-kafka/src/main/java/org/apache/kylin/stream/source/kafka/TimedJsonStreamParser.java
@@ -142,7 +142,7 @@ public final class TimedJsonStreamParser implements IStreamingMessageParser<Cons
if (pathToValue != null) {
result.add(processMultiLevelJson(pathToValue, root));
} else {
- result.add(StringUtils.EMPTY);
+ result.add(null);
}
} else {
result.add(value.toString());