This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 3e46145af [INLONG-7457][Sort] Change changelog mode to capture
update_before for Doris (#7458)
3e46145af is described below
commit 3e46145af8225862a6c6976279638f02cc27aed0
Author: Yizhou Yang <[email protected]>
AuthorDate: Wed Mar 1 16:19:31 2023 +0800
[INLONG-7457][Sort] Change changelog mode to capture update_before for
Doris (#7458)
Co-authored-by: Yizhou Yang <[email protected]>
---
.../org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
diff --git
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java
index 3658c13e4..8e6527c12 100644
---
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java
+++
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java
@@ -24,7 +24,6 @@ import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.connector.ChangelogMode;
import org.apache.flink.table.connector.sink.DynamicTableSink;
import org.apache.flink.table.connector.sink.SinkFunctionProvider;
-import org.apache.flink.types.RowKind;
import org.apache.inlong.sort.base.dirty.DirtyOptions;
import org.apache.inlong.sort.base.dirty.sink.DirtySink;
import org.apache.inlong.sort.doris.internal.GenericDorisSinkFunction;
@@ -84,11 +83,7 @@ public class DorisDynamicTableSink implements
DynamicTableSink {
@Override
public ChangelogMode getChangelogMode(ChangelogMode changelogMode) {
- return ChangelogMode.newBuilder()
- .addContainedKind(RowKind.INSERT)
- .addContainedKind(RowKind.DELETE)
- .addContainedKind(RowKind.UPDATE_AFTER)
- .build();
+ return ChangelogMode.all();
}
@SuppressWarnings({"unchecked"})
