[GitHub] [iceberg] Reo-LEI edited a comment on pull request #2898: Flink: Fix duplicate rows when sync CDC data by FlinkSQL

[GitBox <gi...@apache.org>]

Reo-LEI edited a comment on pull request #2898:
URL: https://github.com/apache/iceberg/pull/2898#issuecomment-919277576


   > @Reo-LEI Thanks for the contribution, sounds like I'm late for the reviewing. Would you like to resolve the conflicts , I think I will get this reviewing tomorrow, thanks.
   
   @openinx Thanks for your reply. Since I discuss this PR with @kbendick  @stevenzwu, I think the implementation of setting `Filter` opr parallelism and use `CombinedKeySelector` to key by equality key and partition key maybe not a good way to reslove this problem. I'm plan to refactor this on this weeken, and maybe you could review this PR after that. :)


-- 
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: issues-unsubscribe@iceberg.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org