[
https://issues.apache.org/jira/browse/FLINK-32637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jianhao.Li updated FLINK-32637:
-------------------------------
Priority: Major (was: Critical)
> 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
> Priority: Major
> 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)
