yuxiqian opened a new pull request, #4319: URL: https://github.com/apache/flink-cdc/pull/4319
This closes FLINK-39230. Currently, transform filter conditions are only applied on the after() part of UPDATE event. * UPDATE before satisfied, after satisfied => emit UPDATE * UPDATE before not satisfied, after not satisfied => nothing * UPDATE before satisfied, after not satisfied => nothing (?) * UPDATE before not satisfied, after satisfied => emit UPDATE (?) A more reasonable solution (like Flink SQL changelog semantics) would be: * UPDATE before satisfied, after not satisfied => emit DELETE (with update before) * UPDATE before not satisfied, after satisfied => emit INSERT (with update after) -- 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]
