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; } }