jianhao.Li created FLINK-32637:
----------------------------------
Summary: The UNNEST function will cause the Delayed Retry Strategy
For Lookup doesn't work
Key: FLINK-32637
URL: https://issues.apache.org/jira/browse/FLINK-32637
Project: Flink
Issue Type: Bug
Components: Table SQL / JDBC, Table SQL / Planner
Affects Versions: 1.16.1
Reporter: jianhao.Li
Attachments: dml.sql, error-flink-sqls.sql, success-flink-sqls.sql
The UNNEST function will cause the Delayed Retry Strategy For Lookup doesn't
work
When I use the UNNEST method in my sql statement to achieve array expansion,
the Delayed Retry Strategy For Lookup has no effect.
The retry is not performed according to the configuration, and there are no
logs or exceptions.
I tried flink on yarn mode and standalone mode and it doesn't work.
See the attachment for the error statements、success statments and source dml in
case.
It is easy to reproduce in sql-client
Here are some information:
version：flink-1.16.1
source: kafka
source data :canal-binlog data
source format: json
look up source: mysql
sink: kafka
sink format:json
Please developers judge whether my case is a bug.
Looking forward to your answer!
[1 feature
doc|https://cwiki.apache.org/confluence/display/FLINK/FLIP-234%3A+Support+Retryable+Lookup+Join+To+Solve+Delayed+Updates+Issue+In+External+Systems]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
