sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From venkatran...@apache.org
Subject git commit: SQOOP-1065: Sqoop2: Remove special lock object in FrameworkManager
Date Sat, 22 Jun 2013 19:22:17 GMT
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 <venkat@hortonworks.com>
Authored: Sat Jun 22 09:51:43 2013 -0700
Committer: Venkat Ranganathan <venkat@hortonworks.com>
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,


Mime
View raw message