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

Reply via email to