[
https://issues.apache.org/jira/browse/FLINK-32637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745340#comment-17745340
]
jianhao.Li commented on FLINK-32637:
------------------------------------
[~lincoln.86xy] Thanks for your reply. I try it
> 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* *funcation* 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:
>
> ||index||value||
> |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!
> 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)
