Merge pull request #18 from taosdata/fix/TS-6006

zitsen · web-flow · commit a7fa0b8d62ce · 2025-02-18T14:12:21.000+08:00
fix: delete RowKind types other than insertion, source does not need …
diff --git a/src/main/java/com/taosdata/flink/table/TDengineTableCdc.java b/src/main/java/com/taosdata/flink/table/TDengineTableCdc.java
@@ -34,9 +34,6 @@ public TDengineTableCdc(String topic, Properties properties) {
     public ChangelogMode getChangelogMode() {
         return ChangelogMode.newBuilder()
                 .addContainedKind(RowKind.INSERT)
-                .addContainedKind(RowKind.UPDATE_BEFORE)
-                .addContainedKind(RowKind.UPDATE_AFTER)
-                .addContainedKind(RowKind.DELETE)
                 .build();
     }
 
diff --git a/src/main/java/com/taosdata/flink/table/TDengineTableSource.java b/src/main/java/com/taosdata/flink/table/TDengineTableSource.java
@@ -38,9 +38,6 @@ public TDengineTableSource(String url, String scanQuery, DataType physicalDataTy
     public ChangelogMode getChangelogMode() {
         return ChangelogMode.newBuilder()
                 .addContainedKind(RowKind.INSERT)
-                .addContainedKind(RowKind.UPDATE_BEFORE)
-                .addContainedKind(RowKind.UPDATE_AFTER)
-                .addContainedKind(RowKind.DELETE)
                 .build();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -34,9 +34,6 @@ public TDengineTableCdc(String topic, Properties properties) {`
`34`	`34`	`public ChangelogMode getChangelogMode() {`
`35`	`35`	`return ChangelogMode.newBuilder()`
`36`	`36`	`.addContainedKind(RowKind.INSERT)`
`37`		`- .addContainedKind(RowKind.UPDATE_BEFORE)`
`38`		`- .addContainedKind(RowKind.UPDATE_AFTER)`
`39`		`- .addContainedKind(RowKind.DELETE)`
`40`	`37`	`.build();`
`41`	`38`	`}`
`42`	`39`
Original file line number	Diff line number	Diff line change
`@@ -38,9 +38,6 @@ public TDengineTableSource(String url, String scanQuery, DataType physicalDataTy`
`38`	`38`	`public ChangelogMode getChangelogMode() {`
`39`	`39`	`return ChangelogMode.newBuilder()`
`40`	`40`	`.addContainedKind(RowKind.INSERT)`
`41`		`- .addContainedKind(RowKind.UPDATE_BEFORE)`
`42`		`- .addContainedKind(RowKind.UPDATE_AFTER)`
`43`		`- .addContainedKind(RowKind.DELETE)`
`44`	`41`	`.build();`
`45`	`42`	`}`
`46`	`43`