[FLINK-32637] The UNNEST function will cause the Delayed Retry Strategy For Lookup doesn't work

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.16.1
• Component/s: Table SQL / JDBC, Table SQL / Planner
• Assignee: Unassigned
• Reporter: lyndon.lee
• Created: 20/Jul/23 09:20
• Updated: 21/Jul/23 02:04

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