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 fd9aac91..6d22c62b 100644
--- a/core/src/main/java/org/apache/sqoop/framework/JobManager.java
+++ b/core/src/main/java/org/apache/sqoop/framework/JobManager.java
@@ -135,12 +135,6 @@ public static void setInstance(JobManager newInstance) {
     */
    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.
     *
@@ -372,7 +366,7 @@ public MSubmission submit(long jobId) {
 
        // 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,