From d48845feb5a241d275e71e77178add42bb63f60c Mon Sep 17 00:00:00 2001 From: "qianhao.zhou" Date: Wed, 7 Jan 2015 19:19:47 +0800 Subject: [PATCH] fix bug --- job/src/main/java/com/kylinolap/job2/common/MapReduceExecutable.java | 2 +- .../com/kylinolap/job2/cube/UpdateCubeInfoAfterBuildExecutable.java | 2 +- .../com/kylinolap/job2/cube/UpdateCubeInfoAfterMergeExecutable.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/job/src/main/java/com/kylinolap/job2/common/MapReduceExecutable.java b/job/src/main/java/com/kylinolap/job2/common/MapReduceExecutable.java index 13bfc61..4fd782e 100644 --- a/job/src/main/java/com/kylinolap/job2/common/MapReduceExecutable.java +++ b/job/src/main/java/com/kylinolap/job2/common/MapReduceExecutable.java @@ -81,7 +81,7 @@ protected ExecuteResult doWork(ExecutableContext context) throws ExecuteExceptio } /* - * stop is triggered by JobService, the Scheduler is not awake of that, so much get the latest value from service + * stop is triggered by JobService, the Scheduler is not awake of that, so * * */ private boolean isStopped() { diff --git a/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterBuildExecutable.java b/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterBuildExecutable.java index 7c4b1d2..47a18f2 100644 --- a/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterBuildExecutable.java +++ b/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterBuildExecutable.java @@ -83,7 +83,7 @@ public void setCubingJobId(String id) { } private String getCubingJobId() { - return CUBING_JOB_ID; + return getParam(CUBING_JOB_ID); } @Override diff --git a/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterMergeExecutable.java b/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterMergeExecutable.java index 7d274bb..c635de3 100644 --- a/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterMergeExecutable.java +++ b/job/src/main/java/com/kylinolap/job2/cube/UpdateCubeInfoAfterMergeExecutable.java @@ -130,6 +130,6 @@ public void setCubingJobId(String id) { } private String getCubingJobId() { - return CUBING_JOB_ID; + return getParam(CUBING_JOB_ID); } }