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

Async IO Allows Custom Action after Final Retry Failure

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • API / DataStream
    • None

    Description

      in Async IO Retry Support, if all retries fail, the record is dropped without any further action. However, there are user cases requiring action after the final retry failure occurs, e.g, log out the input or write the input data to an external storage.  To address this, we propose to add a new API in the AsyncRetryStrategy and make changes accordingly. 

      Attachments

        Activity

          People

            Unassigned Unassigned
            qqibrow Lu Niu
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: