You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by xx...@apache.org on 2022/01/19 08:10:28 UTC
[kylin] 01/02: [KYLIN-5125] `MetadataCleanupJob.isJobComplete` should use `NSparkCubingJob` because kylin4 use spark engine to build cube (No more MR engine)
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 <hu...@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())) {