[kylin] branch master updated: KYLIN-4328 Add code be used to push succeed jobid to hashset.

[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 4e5b9a3  KYLIN-4328 Add code be used to push succeed jobid to hashset.
4e5b9a3 is described below

commit 4e5b9a31ba88292ef6e56129494e034307fe4f01
Author: ggKe <gu...@autohome.com.cn>
AuthorDate: Sat Feb 8 09:45:07 2020 +0800

    KYLIN-4328 Add code be used to push succeed jobid to hashset.
---
 .../main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java
index e3dc194..a1d2e90 100644
--- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java
+++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java
@@ -77,6 +77,7 @@ public abstract class FetcherRunner implements Runnable {
         final Output outputDigest = getExecutableManager().getOutputDigest(id);
         // logger.debug("Job id:" + id + " not runnable");
         if (outputDigest.getState() == ExecutableState.SUCCEED) {
+            succeedJobs.add(id);
             nSUCCEED++;
         } else if (outputDigest.getState() == ExecutableState.ERROR) {
             nError++;