yuxiqian opened a new pull request, #3592:
URL: https://github.com/apache/flink-cdc/pull/3592
This closes FLINK-35982.
One may readjust source table primary keys, partition keys, table options by
specifying them in a Transform block like this:
```yaml
transform:
- projection: '*'
primary-keys: order_id, product_name
partition-keys: order_id
table-options: bucket=1
```
However, if projection field is omitted (which fallbacks to default behavior
that does not change any source table columns), such configuration will not
take effect:
```yaml
transform:
- primary-keys: order_id, product_name
partition-keys: order_id
table-options: bucket=1 # These options will not apply
```
The underlying reason is transform blocks without `projection` was simply
ignored by `PreTransformOperator`, which isn't accurate since other options
like primary keys, partition keys should take effect without projecting
original columns.
--
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]
