Xiqian Yu created FLINK-39230:
---------------------------------
Summary: CDC Pipeline transform should handle partially-applied
filters on UPDATE events
Key: FLINK-39230
URL: https://issues.apache.org/jira/browse/FLINK-39230
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: Xiqian Yu
Assignee: Xiqian Yu
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 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 message was sent by Atlassian Jira
(v8.20.10#820010)
