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

[nic]

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

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


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

commit a16ccbf7b82c50e2983d996d02ac74a7516f0908
Author: chao long <wayn...@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());