You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2019/01/28 00:04:21 UTC
[kylin] branch 2.5.x updated: KYLIN-3494
ArrayIndexOutOfBoundsException may occur in streaming cube building
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch 2.5.x
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.5.x by this push:
new 710d5dc KYLIN-3494 ArrayIndexOutOfBoundsException may occur in streaming cube building
710d5dc is described below
commit 710d5dc514ef3bcf87fef87101324ba47da20beb
Author: shaofengshi <sh...@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 1c94f9c..90f9b70 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
@@ -99,7 +99,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);
}