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 <shaofeng...@apache.org>
Authored: Thu Nov 10 10:48:45 2016 +0800
Committer: shaofengshi <shaofeng...@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;
     }
 }

Reply via email to