diff --git a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java index 8d55d63adb408..8181d20c02b02 100644 --- a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java +++ b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java @@ -955,7 +955,7 @@ private void validateTableConstraint(SqlTableConstraint constraint) { if (constraint.isEnforced()) { throw new ValidationException( "Flink doesn't support ENFORCED mode for " - + "PRIMARY KEY constaint. ENFORCED/NOT ENFORCED controls if the constraint " + + "PRIMARY KEY constraint. ENFORCED/NOT ENFORCED controls if the constraint " + "checks are performed on the incoming/outgoing data. " + "Flink does not own the data therefore the only supported mode " + "is the NOT ENFORCED mode"); diff --git a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java index 26cd1cc8d6328..fe16f551f7c9a 100644 --- a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java +++ b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java @@ -473,7 +473,7 @@ public void testCreateTableWithPrimaryKeyEnforced() { thrown.expect(ValidationException.class); thrown.expectMessage( "Flink doesn't support ENFORCED mode for PRIMARY KEY " - + "constaint. ENFORCED/NOT ENFORCED controls if the constraint " + + "constraint. ENFORCED/NOT ENFORCED controls if the constraint " + "checks are performed on the incoming/outgoing data. " + "Flink does not own the data therefore the only supported mode is the NOT ENFORCED mode"); parse(sql, planner, parser); @@ -1230,7 +1230,7 @@ public void testAlterTableAddPkConstraintEnforced() throws Exception { // Test alter table add enforced thrown.expect(ValidationException.class); thrown.expectMessage( - "Flink doesn't support ENFORCED mode for PRIMARY KEY constaint. " + "Flink doesn't support ENFORCED mode for PRIMARY KEY constraint. " + "ENFORCED/NOT ENFORCED controls if the constraint checks are performed on the " + "incoming/outgoing data. Flink does not own the data therefore the " + "only supported mode is the NOT ENFORCED mode");