Hi Yangxueyong,
Are you sure this is your Flink SQL job? This SQL statement looks very
strange, the table 'test_flink_res2' is both source and sink, and the join
key is null.
Best,
Shammon FY
On Wed, May 10, 2023 at 12:54 PM yangxueyong
wrote:
> flink1.16.1
>
> mysql8.0.33
>
> jdbc-3.1.0-1.16
Hi, yangxueyong,
The filter(where condition) will be pushed down to the source if the
connector implements the interface `SupportsFilterPushDown`.
In your case, the sql planner analyzed that the records sent by
`test_flink_res1` would satisfy the conditions (`name` =
'abc0.11317691217472489') and
