diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutor.java b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutor.java index 5dc3c0b1..e94a19be 100644 --- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutor.java +++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutor.java @@ -81,7 +81,7 @@ public void deleteTableData(String tableName) { public void migrateData(String fromTable, String toTable) { String insertQuery = "INSERT INTO " + toTable + - " ( SELECT * FROM " + fromTable + " )"; + " SELECT * FROM " + fromTable; Statement stmt = null; Boolean oldAutoCommit = null; try {