[ 
https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726119#comment-17726119
 ] 

Xin Chen edited comment on FLINK-32188 at 5/25/23 9:16 AM:
-----------------------------------------------------------

I debugged the Flink source code and found that predicate parsing was performed 
in the *PushFilterIntoTableSourceScanRule *of org. apache. Flink. table. 
planner. plan. rules. logical,
 !screenshot-1.png! 

In RexNodeExtractor.extractConjunctiveConditions,when it finally calls the 
visitCall method and parses the specified array input after 'where', it parses 
the operator as ARRAY and the kind as arrayvalueconstructor. It can be seen 
that there is no corresponding operator in the match method, and ultimately 
matches and enters the lookupFunction

 !image-2023-05-25-17-16-02-288.png! 


was (Author: JIRAUSER298666):
I debugged the Flink source code and found that predicate parsing was performed 
in the *PushFilterIntoTableSourceScanRule *of org. apache. Flink. table. 
planner. plan. rules. logical,
 !screenshot-1.png! 

> Does the custom connector not support pushing down "where" query predicates 
> to query fields of array type?
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-32188
>                 URL: https://issues.apache.org/jira/browse/FLINK-32188
>             Project: Flink
>          Issue Type: Technical Debt
>          Components: Table SQL / Planner
>    Affects Versions: 1.12.2, 1.17.0, 1.16.1
>            Reporter: Xin Chen
>            Priority: Major
>         Attachments: image-2023-05-25-17-16-02-288.png, screenshot-1.png
>
>
> When I customized a data source connector which assumed as image-connector, I 
> found that when creating a table with ddl, I specified a field URL as an 
> array type. When submitting an SQL task with Flink, I specified query this 
> field as a fixed array. For example, select * from image source where 
> URL=ARRAY ['/flink. jpg', '/flink_1. jpg'], but I found that it couldn't 
> obtain the corresponding predicate filters at all.
> Does the custom connector not support  to query fields of array type with 
> "where"?



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to