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