[
https://issues.apache.org/jira/browse/FLINK-37667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17944019#comment-17944019
]
yux commented on FLINK-37667:
-----------------------------
+1 for this change.
Also, if we're going to chain source and transform operators together, is it
unnecessary to filter out unused columns in PrePartition operator, since it
doesn't help saving network payloads but introduces extra cost during binary
packing & unpacking?
> Make PostTransformOperator always chain with before Operator
> ------------------------------------------------------------
>
> Key: FLINK-37667
> URL: https://issues.apache.org/jira/browse/FLINK-37667
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: cdc-3.4.0
> Reporter: Yanquan Lv
> Priority: Major
> Attachments: image-2025-04-14-10-46-57-983.png
>
>
> We can replace the nodes of FORWARD relation with nodes connected together to
> improve performance.
> !image-2025-04-14-10-46-57-983.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
