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 2016/11/10 02:48:50 UTC

kylin git commit: KYLIN-1726 fix a NPE

Repository: kylin
Updated Branches:
  refs/heads/master 862aaabe6 -> 5ea095a32


KYLIN-1726 fix a NPE


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5ea095a3
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5ea095a3
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5ea095a3

Branch: refs/heads/master
Commit: 5ea095a3251a6588331a26d57ae3bdee4eb61fbb
Parents: 862aaab
Author: shaofengshi <sh...@apache.org>
Authored: Thu Nov 10 10:48:45 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Thu Nov 10 10:48:45 2016 +0800

----------------------------------------------------------------------
 .../main/java/org/apache/kylin/source/SourcePartition.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/5ea095a3/core-metadata/src/main/java/org/apache/kylin/source/SourcePartition.java
----------------------------------------------------------------------
diff --git a/core-metadata/src/main/java/org/apache/kylin/source/SourcePartition.java b/core-metadata/src/main/java/org/apache/kylin/source/SourcePartition.java
index cf89580..e489704 100644
--- a/core-metadata/src/main/java/org/apache/kylin/source/SourcePartition.java
+++ b/core-metadata/src/main/java/org/apache/kylin/source/SourcePartition.java
@@ -104,8 +104,12 @@ public class SourcePartition {
         copy.setEndDate(origin.getEndDate());
         copy.setStartOffset(origin.getStartOffset());
         copy.setEndOffset(origin.getEndOffset());
-        copy.setSourcePartitionOffsetStart(new HashMap<>(origin.getSourcePartitionOffsetStart()));
-        copy.setSourcePartitionOffsetEnd(new HashMap<>(origin.getSourcePartitionOffsetEnd()));
+        if (origin.getSourcePartitionOffsetStart() != null) {
+            copy.setSourcePartitionOffsetStart(new HashMap<>(origin.getSourcePartitionOffsetStart()));
+        }
+        if (origin.getSourcePartitionOffsetEnd() != null) {
+            copy.setSourcePartitionOffsetEnd(new HashMap<>(origin.getSourcePartitionOffsetEnd()));
+        }
         return copy;
     }
 }