[ 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)