diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CloneActionITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CloneActionITCase.java index a55b01cc203b..d6719b124327 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CloneActionITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CloneActionITCase.java @@ -375,21 +375,22 @@ public void testCloneWithSchemaEvolution(String invoker) throws Exception { tEnv.executeSql("USE CATALOG sourcecat"); tEnv.executeSql( - "CREATE TABLE t (\n" - + " pt STRING,\n" - + " k INT,\n" - + " v INT,\n" - + " PRIMARY KEY (pt, k) NOT ENFORCED\n" - + ") PARTITIONED BY (pt) WITH (\n" - + " 'changelog-producer' = 'lookup'\n" - + ")"); + "CREATE TABLE t (\n" + + " pt STRING,\n" + + " k INT,\n" + + " v INT,\n" + + " PRIMARY KEY (pt, k) NOT ENFORCED\n" + + ") PARTITIONED BY (pt) WITH (\n" + + " 'changelog-producer' = 'lookup'\n" + + ")") + .await(); tEnv.executeSql( "INSERT INTO t VALUES " + "('one', 1, 10), " + "('one', 2, 20), " + "('two', 1, 100)") .await(); - tEnv.executeSql("ALTER TABLE t ADD v2 STRING AFTER v"); + tEnv.executeSql("ALTER TABLE t ADD v2 STRING AFTER v").await(); tEnv.executeSql( "INSERT INTO t VALUES " + "('one', 2, 21, 'apple'), "