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 2015/11/05 02:33:37 UTC
[14/19] incubator-kylin git commit: another NPE
another NPE
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/2d2895ae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/2d2895ae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/2d2895ae
Branch: refs/heads/KYLIN-1112-2
Commit: 2d2895ae142762cbbb5d4342d7b3f6fee96eb6ad
Parents: fff4a30
Author: shaofengshi <sh...@apache.org>
Authored: Mon Nov 2 13:31:28 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Thu Nov 5 09:24:17 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/2d2895ae/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
index 8247295..670972a 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
@@ -75,7 +75,8 @@ public class InvertedIndexMapper<KEYIN> extends KylinMapper<KEYIN, Object, LongW
rec.reset();
for (int i = 0; i < row.length; i++) {
Object fieldValue = row[i];
- rec.setValueString(i, fieldValue == null ? null : fieldValue.toString());
+ if (fieldValue != null)
+ rec.setValueString(i, fieldValue == null ? null : fieldValue.toString());
}
outputKey.set(rec.getTimestamp());