cshuo commented on PR #4460: URL: https://github.com/apache/flink-cdc/pull/4460#issuecomment-4888416309
Could we avoid hard-coding the `<prefix>-schema-operator` derivation in the Hudi connector? `FlinkPipelineComposer` already has the canonical UID generation logic, while Paimon/Iceberg/MaxCompute currently also read `PIPELINE_SCHEMA_OPERATOR_UID` directly before creating their `SchemaEvolutionClient` operator IDs. It may be better to move this final schema operator UID derivation into a shared helper in common and reuse it from both the composer and schema-aware sink factories, so the UID format does not drift across connectors. -- 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]
