diff --git a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java index 4968c0d8..2e5abb82 100644 --- a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java +++ b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbySchemaQuery.java @@ -450,7 +450,7 @@ public final class DerbySchemaQuery { // Delete all forms for a given connector public static final String STMT_DELETE_FORMS_FOR_CONNECTOR = "DELETE FROM " + TABLE_SQ_FORM - + " WHERE " + COLUMN_SQN_CONNECTOR + " = ?"; + + " WHERE " + COLUMN_SQF_CONNECTOR + " = ?"; // Delete all inputs for a given connector public static final String STMT_DELETE_INPUTS_FOR_CONNECTOR =