diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala index 12c7cd22c2c9a..3fddb62b11368 100644 --- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala +++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala @@ -988,7 +988,7 @@ class CatalogTableITCase(isStreamingMode: Boolean) extends AbstractTestBase { .getSchema assert(tableSchema1.getPrimaryKey.isPresent) assertEquals( - "CONSTRAINT `ct1` PRIMARY KEY (`a`)", + "CONSTRAINT `ct1` PRIMARY KEY (`a`) NOT ENFORCED", tableSchema1.getPrimaryKey.get().asSummaryString()) // alter table drop constraint