remove DeleteStrategy.java

alibaba · Jan 8, 2025 · 078ed2c · 078ed2c
1 parent 51cb5e6
commit 078ed2c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 41 deletions.
diff --git a/...onnector-flink/src/main/java/com/alibaba/fluss/connector/flink/FlinkConnectorOptions.java b/...onnector-flink/src/main/java/com/alibaba/fluss/connector/flink/FlinkConnectorOptions.java
@@ -102,7 +102,10 @@ public class FlinkConnectorOptions {
             ConfigOptions.key("sink.ignore_delete")
                     .booleanType()
                     .defaultValue(false)
-                    .withDescription("Whether to ignore retract（-U/-D) record.");
+                    .withDescription(
+                            "Whether to ignore DELETE and UPDATE_BEFORE messages. "
+                                    + "Enabling this config for Log Table can allow "
+                                    + "Log Table to be used as a sink of a changelog stream.");
 
     // --------------------------------------------------------------------------------------------
     // table storage specific options

diff --git a/...nnector-flink/src/main/java/com/alibaba/fluss/connector/flink/options/DeleteStrategy.java b/...nnector-flink/src/main/java/com/alibaba/fluss/connector/flink/options/DeleteStrategy.java