[kylin] branch 2.6.x updated: KYLIN-3494 ArrayIndexOutOfBoundsException may occur in streaming cube building

[shaofengshi]

This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/2.6.x by this push:
     new 990ec5d  KYLIN-3494 ArrayIndexOutOfBoundsException may occur in 
streaming cube building
990ec5d is described below

commit 990ec5dac4fb175b0c4d2dab609794cd26f4e62a
Author: shaofengshi <shaofeng...@apache.org>
AuthorDate: Mon Jan 28 08:04:09 2019 +0800

    KYLIN-3494 ArrayIndexOutOfBoundsException may occur in streaming cube 
building
---
 .../src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java 
b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java
index d709572..6f99e29 100644
--- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java
+++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java
@@ -87,7 +87,7 @@ public class KafkaMRInput extends KafkaInputBase implements 
IMRInput {
         @Override
         public Collection<String[]> parseMapperInput(Object mapperInput) {
             Text text = (Text) mapperInput;
-            String[] columns = Bytes.toString(text.getBytes(), 0, 
text.getLength()).split(delimiter);
+            String[] columns = Bytes.toString(text.getBytes(), 0, 
text.getLength()).split(delimiter, -1);
             return Collections.singletonList(columns);
         }