yuxiqian opened a new pull request, #4310:
URL: https://github.com/apache/flink-cdc/pull/4310
This closes FLINK-39230 and FLINK-39232.
Currently, transform module supports a bizarre feature: one may define
multiple transform rules like this:
```
transform:
- source-table: foo.bar
projection: \*, proj_1
filter: PREDICATE
- source-table: foo.bar
projection: \*, proj_2
```
Data rows in `mydb.web_order` that matches `PREDICATE` will be handled in
rule #1, while others will be handled in rule #2. Such behavior also requires
partially applied rules must emit compatible schemas, sometimes unexpected.
--
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]
