[
https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452788#comment-17452788
]
Wenlong Lyu commented on FLINK-25149:
-------------------------------------
[~waittting] currently the table planner will validate the DynamicTableSource
before doing the optimization, you should make sure that the original table
source created by factory can work well without push down.
> 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)