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 f4be6395..575a8bb8 100644
--- a/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
+++ b/core/src/main/java/org/apache/sqoop/framework/FrameworkManager.java
@@ -312,6 +312,7 @@ public static MSubmission submit(long jobId) {
       connectorConnection, connectorJob,
       frameworkConnection, frameworkJob);
     request.setJobName(job.getName());
+    request.setJobId(job.getPersistenceId());
 
     // Let's register all important jars
     // sqoop-common
diff --git a/core/src/main/java/org/apache/sqoop/framework/SubmissionRequest.java b/core/src/main/java/org/apache/sqoop/framework/SubmissionRequest.java
index c70a5cc5..9f471b56 100644
--- a/core/src/main/java/org/apache/sqoop/framework/SubmissionRequest.java
+++ b/core/src/main/java/org/apache/sqoop/framework/SubmissionRequest.java
@@ -43,6 +43,11 @@ public class SubmissionRequest {
    */
   String jobName;
 
+  /**
+   * Associated job (from metadata perspective) id
+   */
+  long jobId;
+
   /**
    * Connector instance associated with this submission request
    */
@@ -111,6 +116,14 @@ public void setJobName(String jobName) {
     this.jobName = jobName;
   }
 
+  public long getJobId() {
+    return jobId;
+  }
+
+  public void setJobId(long jobId) {
+    this.jobId = jobId;
+  }
+
   public SqoopConnector getConnector() {
     return connector;
   }
diff --git a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java
index b8415e3f..15cb4765 100644
--- a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java
+++ b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java
@@ -185,7 +185,12 @@ public boolean submit(SubmissionRequest generalRequest) {
 
     try {
       Job job = Job.getInstance(configuration);
-      job.setJobName(request.getJobName());
+
+      if(request.getJobName() != null) {
+        job.setJobName("Sqoop: " + request.getJobName());
+      } else {
+        job.setJobName("Sqoop job with id: " + request.getJobId());
+      }
 
       job.setInputFormatClass(request.getInputFormatClass());