You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@batchee.apache.org by st...@apache.org on 2015/11/29 16:18:42 UTC
incubator-batchee git commit: BATCHEE-73 fixed stochastic tck-test
failure
Repository: incubator-batchee
Updated Branches:
refs/heads/master f16e52f91 -> 77a0a69f3
BATCHEE-73 fixed stochastic tck-test failure
Project: http://git-wip-us.apache.org/repos/asf/incubator-batchee/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-batchee/commit/77a0a69f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-batchee/tree/77a0a69f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-batchee/diff/77a0a69f
Branch: refs/heads/master
Commit: 77a0a69f342ffcf32b3aef2b9e1d89a7ba9e71b9
Parents: f16e52f
Author: Reinhard Sandtner <rs...@apache.org>
Authored: Mon Nov 23 15:08:55 2015 +0100
Committer: Mark Struberg <st...@apache.org>
Committed: Sun Nov 29 16:06:20 2015 +0100
----------------------------------------------------------------------
.../java/org/apache/batchee/container/impl/JobOperatorImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-batchee/blob/77a0a69f/jbatch/src/main/java/org/apache/batchee/container/impl/JobOperatorImpl.java
----------------------------------------------------------------------
diff --git a/jbatch/src/main/java/org/apache/batchee/container/impl/JobOperatorImpl.java b/jbatch/src/main/java/org/apache/batchee/container/impl/JobOperatorImpl.java
index 4003d6d..790def2 100755
--- a/jbatch/src/main/java/org/apache/batchee/container/impl/JobOperatorImpl.java
+++ b/jbatch/src/main/java/org/apache/batchee/container/impl/JobOperatorImpl.java
@@ -173,7 +173,8 @@ public class JobOperatorImpl implements JobOperator {
final InternalJobExecution jobEx = persistenceManagerService.jobOperatorGetJobExecution(executionId);
// if it is not in STARTED or STARTING state, mark it as ABANDONED
- if (jobEx.getBatchStatus().equals(BatchStatus.STARTED) || jobEx.getBatchStatus().equals(BatchStatus.STARTING)) {
+ BatchStatus status = jobEx.getBatchStatus();
+ if (status == BatchStatus.STARTING || status == BatchStatus.STARTED) {
throw new JobExecutionIsRunningException("Job Execution: " + executionId + " is still running");
}