diff --git a/client/src/main/java/org/apache/sqoop/client/shell/CreateJobFunction.java b/client/src/main/java/org/apache/sqoop/client/shell/CreateJobFunction.java
index 4fc2a434..f5155d5c 100644
--- a/client/src/main/java/org/apache/sqoop/client/shell/CreateJobFunction.java
+++ b/client/src/main/java/org/apache/sqoop/client/shell/CreateJobFunction.java
@@ -76,7 +76,7 @@ private void createJob(Long connectionId, String type) throws IOException {
     printlnResource(Constants.RES_CREATE_CREATING_JOB, connectionId);
 
     ConsoleReader reader = new ConsoleReader();
-    MJob job = client.newJob(connectionId, MJob.Type.valueOf(type));
+    MJob job = client.newJob(connectionId, MJob.Type.valueOf(type.toUpperCase()));
 
     ResourceBundle connectorBundle = client.getResourceBundle(job.getConnectorId());
     ResourceBundle frameworkBundle = client.getFrameworkResourceBundle();