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 <[email protected]> Authored: Mon Nov 26 08:39:08 2012 -0800 Committer: Bilung Lee <[email protected]> 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; }
