You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by bl...@apache.org on 2012/11/26 18:13:26 UTC
[4/5] git commit: SQOOP-673 Call update() only in job running status
(Jarek Jarcec Cecho)
SQOOP-673 Call update() only in job running status
(Jarek Jarcec Cecho)
Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/13c5c068
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/13c5c068
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/13c5c068
Branch: refs/heads/sqoop2
Commit: 13c5c0689f0387b7da1a510320015623599abf09
Parents: 80a11f9
Author: Bilung Lee <bl...@apache.org>
Authored: Mon Nov 26 08:39:08 2012 -0800
Committer: Bilung Lee <bl...@apache.org>
Committed: Mon Nov 26 08:39:08 2012 -0800
----------------------------------------------------------------------
.../apache/sqoop/framework/FrameworkManager.java | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/sqoop/blob/13c5c068/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java b/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
index c9c9cf4..79c9acc 100644
--- a/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
+++ b/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
@@ -463,7 +463,10 @@ public final class FrameworkManager {
return new MSubmission(jobId, new Date(), SubmissionStatus.NEVER_EXECUTED);
}
- update(submission);
+ // If the submission is in running state, let's update it
+ if(submission.getStatus().isRunning()) {
+ update(submission);
+ }
return submission;
}