[kylin] branch master updated: KYLIN-4049 Make storage clean configurable for refreshing job

[ni...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

nic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/master by this push:
     new 7fe98c9  KYLIN-4049 Make storage clean configurable for refreshing job
7fe98c9 is described below

commit 7fe98c9c6082444a29451f7a2dce8274e9794ef9
Author: chao long <wa...@qq.com>
AuthorDate: Tue Jun 18 17:13:36 2019 +0800

    KYLIN-4049 Make storage clean configurable for refreshing job
---
 .../main/java/org/apache/kylin/storage/hbase/steps/HBaseJobSteps.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseJobSteps.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseJobSteps.java
index 205abe2..40da29a 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseJobSteps.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseJobSteps.java
@@ -22,6 +22,7 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 
+import org.apache.kylin.common.KylinConfig;
 import org.apache.kylin.common.util.StringUtil;
 import org.apache.kylin.cube.CubeInstance;
 import org.apache.kylin.cube.CubeSegment;
@@ -241,7 +242,7 @@ public abstract class HBaseJobSteps extends JobBuilderSupport {
         CubeSegment oldSegment = ((CubeInstance)seg.getRealization()).getOriginalSegmentToRefresh(seg);
 
         // refresh segment
-        if (oldSegment != null) {
+        if (oldSegment != null && KylinConfig.getInstanceFromEnv().cleanStorageAfterDelOperation()) {
             // delete old hdfs job
             toDeletePaths.addAll(getRefreshingHDFSPaths());