yuxiqian commented on PR #3977:
URL: https://github.com/apache/flink-cdc/pull/3977#issuecomment-2774458157
It seems we already have the pipeline option `schema.operator.uid` to
configure UID, but only for Schema Operators. So maybe the description of
`operator.uid.prefix` isn't precise as it doesn't apply to “all pipeline
operators”.
Agree that keeping all operators UID fixed (not only for schema operators)
is the right thing, so perhaps we can deprecate `schema.operator.uid` and favor
`operator.uid.prefix`? We may keep state backwards compatibility with extra
checking:
| | `schema.operator.uid` set
| `schema.operator.uid` not set
|
|-------------------------------|-----------------------------------------------------------------------------------|----------------------------------------------------------------------------------------------------------------------------------|
| `operator.uid.prefix` set | Incompatible configurations<br>Throw
exceptions (?) | Set fixed UID for all
operators<br>(including schema operators)
|
| `operator.uid.prefix` not set | Only set UID for schema
operators<br>(behavior unchanged for state compatibility) | Only set UID for
schema operators<br>with the default value of
`schema.operator.uid`<br>(behavior unchanged for state compatibility) |
and remove `schema.operator.uid` as a breaking change later. WDYT?
--
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]
