[kylin] 01/02: [KYLIN-5125] `MetadataCleanupJob.isJobComplete` should use `NSparkCubingJob` because kylin4 use spark engine to build cube (No more MR engine)

[xxyu]

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

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

commit a261311a3150210f6d957726d6bf3749b78321b8
Author: hujiahua <hujia...@youzan.com>
AuthorDate: Mon Nov 15 16:41:25 2021 +0800

    [KYLIN-5125] `MetadataCleanupJob.isJobComplete` should use 
`NSparkCubingJob` because kylin4 use spark engine to build cube (No more MR 
engine)
---
 .../src/main/java/org/apache/kylin/rest/job/MetadataCleanupJob.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/server-base/src/main/java/org/apache/kylin/rest/job/MetadataCleanupJob.java 
b/server-base/src/main/java/org/apache/kylin/rest/job/MetadataCleanupJob.java
index fe64660..3ae2fb1 100644
--- 
a/server-base/src/main/java/org/apache/kylin/rest/job/MetadataCleanupJob.java
+++ 
b/server-base/src/main/java/org/apache/kylin/rest/job/MetadataCleanupJob.java
@@ -27,7 +27,7 @@ import org.apache.hadoop.fs.Path;
 import org.apache.kylin.common.KylinConfig;
 import org.apache.kylin.common.persistence.ResourceStore;
 import org.apache.kylin.common.util.HadoopUtil;
-import org.apache.kylin.engine.mr.CubingJob;
+import org.apache.kylin.engine.spark.job.NSparkCubingJob;
 import org.apache.kylin.job.dao.ExecutableDao;
 import org.apache.kylin.job.dao.ExecutableOutputPO;
 import org.apache.kylin.job.dao.ExecutablePO;
@@ -106,7 +106,7 @@ public class MetadataCleanupJob {
             ExecutableOutputPO output = executableDao.getJobOutput(jobId);
             String status = output.getStatus();
             String jobType = job.getType();
-            if (jobType.equals(CubingJob.class.getName())
+            if (jobType.equals(NSparkCubingJob.class.getName())
                     || jobType.equals(CheckpointExecutable.class.getName())) {
                 if (StringUtils.equals(status, 
ExecutableState.SUCCEED.toString())
                         || StringUtils.equals(status, 
ExecutableState.DISCARDED.toString())) {