Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-32637

The UNNEST function will cause the Delayed Retry Strategy For Lookup doesn't work

    XMLWordPrintableJSON

Details

    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

       

      Attachments

        1. dml.sql
          0.4 kB
          jianhao.Li
        2. error-flink-sqls.sql
          2 kB
          jianhao.Li
        3. success-flink-sqls.sql
          2 kB
          jianhao.Li

        Activity

          People

            Unassigned Unassigned
            lyndon.lee jianhao.Li
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: