JunboWang created FLINK-36846:
---------------------------------
Summary: Composer support add custom Operator after Source
Key: FLINK-36846
URL: https://issues.apache.org/jira/browse/FLINK-36846
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.2.1, cdc-3.3.0
Reporter: JunboWang
Currently, Flink CDC operators include Transform (PreTransformOperator,
PostTransformOperator), route (SchemaOperator), source, and sink. Is it
possible to extend Composer to allow users to embed custom operators within the
stream? Some potential functionalities that custom operators could support
include DDL collection and sampling synchronization for validation purposes.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
