Thanks for you explain.
It seems that what you actually need is a general connector parameter in 'WITH' 
block like 'filter-pushdown-enabled', and the specific connector rejects all 
filters that could otherwise be pushed down in the connector.
Please forgive me if I'm wrong.




--

    Best!
    Xuyang





在 2023-10-24 14:34:15,"Jiabao Sun" <jiabao....@xtransfer.cn.INVALID> 写道:
>Thanks Xuyang,
>
>The table.optimizer.source.predicate-pushdown-enabled options do not provide 
>fine-grained configuration for each source.
>
>Suppose we have an SQL query with two sources: Kafka and a database (CDC). 
>The database is sensitive to pressure, and we want to configure it to not 
>perform filter pushdown to the database source. 
>However, we still want to perform filter pushdown to the Kafka source to 
>decrease network IO.
>
>
>Best,
>Jiabao 
> <https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/table/config/#table-optimizer-source-predicate-pushdown-enabled>
>
>> 2023年10月24日 14:24,Xuyang <xyzhong...@163.com> 写道:
>> 
>> Hi, the existant configuration 
>> 'table.optimizer.source.predicate-pushdown-enabled' seems to do what you 
>> want. 
>> Can you describe more clearly the difference between what you want and this 
>> configuration ?
>> 
>> 
>> 
>> 
>> 
>> 
>> 
>> --
>> 
>>    Best!
>>    Xuyang
>> 
>> 
>> 
>> 
>> 
>> At 2023-10-24 14:12:14, "Jiabao Sun" <jiabao....@xtransfer.cn.INVALID> wrote:
>>> Hi Devs,
>>> 
>>> I would like to start a discussion on support configuration to disable 
>>> filter pushdown for Table/SQL Sources[1].
>>> 
>>> Currently, Flink SQL does not support the ability for users to enable or 
>>> disable filter pushdown. 
>>> However, filter pushdown has some side effects, such as additional 
>>> computational pressure on external systems. 
>>> Moreover, Improper queries can lead to issues such as full table scans, 
>>> which in turn can impact the stability of external systems.
>>> 
>>> I propose to support configuration to disable filter push down for 
>>> Table/SQL sources to let user decide whether to perform filter pushdown.
>>> 
>>> Looking forward to your feedback.
>>> 
>>> [1] 
>>> https://docs.google.com/document/d/1QsbOi9InvmfwFr8YbrnnXOKLPnb8JnqhXIMbGd68SFU/edit?usp=sharing
>>> 
>>> Best,
>>> Jiabao
>

Reply via email to