Re: [PR] [cdc] fix enable-delete option not work [doris-flink-connector]

2024-08-05 Thread via GitHub
JNSimba merged PR #455: URL: https://github.com/apache/doris-flink-connector/pull/455 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr..

Re: [PR] [cdc] fix enable-delete option not work [doris-flink-connector]

2024-08-05 Thread via GitHub
DongLiang-0 commented on code in PR #455: URL: https://github.com/apache/doris-flink-connector/pull/455#discussion_r1703713712 ## flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java: ## @@ -111,6 +112,7 @@ public J

Re: [PR] [cdc] fix enable-delete option not work [doris-flink-connector]

2024-08-05 Thread via GitHub
DongLiang-0 commented on code in PR #455: URL: https://github.com/apache/doris-flink-connector/pull/455#discussion_r1703713675 ## flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java: ## @@ -116,6 +119,10

[PR] [cdc] fix enable-delete option not work [doris-flink-connector]

2024-08-05 Thread via GitHub
vinlee19 opened a new pull request, #455: URL: https://github.com/apache/doris-flink-connector/pull/455 # Proposed changes Issue Number: close #xxx ## Problem Summary: In the previous version, when we set `enable-delete=false`, the flink-connector-doris would also synchroniz