diff --git a/src/java/org/apache/sqoop/tool/ImportTool.java b/src/java/org/apache/sqoop/tool/ImportTool.java index 10f0cb9e..2627726c 100644 --- a/src/java/org/apache/sqoop/tool/ImportTool.java +++ b/src/java/org/apache/sqoop/tool/ImportTool.java @@ -166,7 +166,7 @@ private Object getMaxColumnId(SqoopOptions options) throws SQLException { String query; sb.append("SELECT MAX("); - sb.append(options.getIncrementalTestColumn()); + sb.append(manager.escapeTableName(options.getIncrementalTestColumn())); sb.append(") FROM "); if (options.getTableName() != null) {