liming30 opened a new pull request, #1010: URL: https://github.com/apache/incubator-paimon/pull/1010
### Purpose Integrate update in flink-1.17. #787 Although update is supported in Flink 1.17, for the sink operators, only `update_after` messages can be received, which limits the usage. In my implementation, only `ChangelogWithKeyFileStoreTable` with `merge-engine` as `deduplicate` or `partial-update` is supported. For other cases, an `UnsupportedOperationException` will be thrown because old data cannot be handled correctly. ### Tests Added following IT cases to verify this change: - org.apache.paimon.flink.StreamingWarehouseITCase#testUpdateWithPrimaryKey - org.apache.paimon.flink.StreamingWarehouseITCase#testUpdateWithoutPrimaryKey ### API and Format No. ### Documentation Yes, update statement is supported for flink 1.17. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
