[
https://issues.apache.org/jira/browse/FLINK-37667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17944019#comment-17944019
]
yux edited comment on FLINK-37667 at 4/14/25 6:27 AM:
------------------------------------------------------
+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 PreTransform operator, since it
doesn't help saving network payloads but introduces extra cost during binary
packing & unpacking?
was (Author: JIRAUSER300787):
+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)
