[
https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452845#comment-17452845
]
Wenlong Lyu commented on FLINK-25149:
-------------------------------------
[~waittting] no, source function will not execute in optimization, you can
refer more details in DynamicSourceUtils#validateScanSource.
getScanRuntimeProvider will be executed again at the end of the optimization,
the parameters you passed by pushdown will be available at that time.
> getScanRuntimeProvider method called before the pushDown method,
> ----------------------------------------------------------------
>
> Key: FLINK-25149
> URL: https://issues.apache.org/jira/browse/FLINK-25149
> Project: Flink
> Issue Type: Bug
> Reporter: waittting
> Priority: Major
>
> ```
> public class CCDynamicTableSource implements ScanTableSource,
> SupportsLimitPushDown, SupportsFilterPushDown, SupportsProjectionPushDown {}
> ```
> Why is the getScanRuntimeProvider method called before the pushDown method,
> so that the parameters I get in the pushDown are not available in the
> getScanRuntimeProvider?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
