Updated Branches: refs/heads/sqoop2 9920db114 -> 05bd42e18
SQOOP-1065: Sqoop2: Remove special lock object in FrameworkManager (Jarek Jarcec Cecho via Venkat Ranganathan) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/05bd42e1 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/05bd42e1 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/05bd42e1 Branch: refs/heads/sqoop2 Commit: 05bd42e1840aa8d58034ab4eab1c92e1c1e47db1 Parents: 9920db1 Author: Venkat Ranganathan <[email protected]> Authored: Sat Jun 22 09:51:43 2013 -0700 Committer: Venkat Ranganathan <[email protected]> Committed: Sat Jun 22 09:51:43 2013 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/sqoop/framework/JobManager.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/05bd42e1/core/src/main/java/org/apache/sqoop/framework/JobManager.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/sqoop/framework/JobManager.java b/core/src/main/java/org/apache/sqoop/framework/JobManager.java index fd9aac9..6d22c62 100644 --- a/core/src/main/java/org/apache/sqoop/framework/JobManager.java +++ b/core/src/main/java/org/apache/sqoop/framework/JobManager.java @@ -136,12 +136,6 @@ public class JobManager { private long updateSleep; /** - * Mutex for creating new submissions. We're not allowing more then one - * running submission for one job. - */ - private final Object submissionMutex = new Object(); - - /** * Base notification URL. * * Framework manager will always add job id. @@ -372,7 +366,7 @@ public class JobManager { // Make sure that this job id is not currently running and submit the job // only if it's not. - synchronized (submissionMutex) { + synchronized (getClass()) { MSubmission lastSubmission = repository.findSubmissionLastForJob(jobId); if(lastSubmission != null && lastSubmission.getStatus().isRunning()) { throw new SqoopException(FrameworkError.FRAMEWORK_0002,
