From 028b830fa4c0a4c841e299e004ffc1db5269b56f Mon Sep 17 00:00:00 2001
From: yejunhao <yejunhao.yjh@alibaba-inc.com>
Date: Wed, 24 Apr 2024 19:06:24 +0800
Subject: [PATCH] fix comment

---
 .../java/org/apache/paimon/flink/BatchFileStoreITCase.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
index 815d819c7a110..ec7b89b5f57c8 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
+++ b/paimon-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')");