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

Try to recover from failure in TwoPhaseCommitSinkFunction.beginTransaction

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • 1.4.0
    • 1.4.0
    • None
    • None

    Description

      Currently when using TwoPhaseCommitSinkFunction, if there is some intermittent failure in "beginTransaction", not only the snapshot that triggered this call fail, but also any subsequent write requests will fail also, rendering such sink unusable until application restart.

      This issue is in code that hasn't been released yet.

      Attachments

        Issue Links

          is cloned by

          New Feature - A new feature of the product, which has yet to be developed. FLINK-7497 Allow users to add custom user context stored in state in TwoPhaseCommitSinkFunction

          • Major - Major loss of function.
          • Closed

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-7498 Bind together state fields of TwoPhaseCommitSinkFunction

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #4561

          Activity

            People

              pnowojski Piotr Nowojski
              pnowojski Piotr Nowojski
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: