[
https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452837#comment-17452837
]
waittting commented on FLINK-25149:
-----------------------------------
I'm sure the original table source created by factory can work well without
push down.
Will the SourceFunction code be executed after Validate the DynamicTableSource?
I'm more interested in how to pass the parameters obtained by pushDown to the
CCDynamicSourceFunction in the getScanRuntimeProvider method
> 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)
