[kylin] branch master updated: KYLIN-4246 Fix for null value and non-exist value in json parser.

[nic]

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 <hit_la...@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());