[
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 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!
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:
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!
[https://cwiki.apache.org/confluence/display/FLINK/FLIP-234%3A+Support+Retryable+Lookup+Join+To+Solve+Delayed+Updates+Issue+In+External+Systems|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 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!
> 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)
