fix comment

apache · Apr 24, 2024 · 028b830 · 028b830
1 parent e02085c
commit 028b830
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java b/...flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
@@ -454,8 +454,7 @@ public void testDeletePartitionWithChangelog(String producer) throws Exception {
                 .containsExactlyInAnyOrder(
                         Row.ofKind(RowKind.INSERT, 1, 1, "A"),
                         Row.ofKind(RowKind.INSERT, 2, 2, "B"));
-        sql(
-                "DELETE FROM ignore_delete /*+ OPTIONS('delete.force-produce-changelog'='true') */ WHERE pt = 1");
+        sql("DELETE FROM ignore_delete WHERE pt = 1");
         assertThat(iterator.collect(1))
                 .containsExactlyInAnyOrder(Row.ofKind(RowKind.DELETE, 1, 1, "A"));
         sql("INSERT INTO ignore_delete VALUES (1, 1, 'B')");