You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2023/03/01 08:19:37 UTC
[inlong] branch master updated: [INLONG-7457][Sort] Change changelog mode to capture update_before for Doris (#7458)
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 <32...@users.noreply.github.com>
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 <yi...@tencent.com>
---
.../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"})