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

FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.4.2
    • Fix Version/s: 1.5.0
    • Component/s: Connectors / Kafka
    • Labels:
      None

      Description

      FlinkKafkaProducer011 can throw ProducerFencedExceptions if multiple sinks are used within the same sub-task.  This can happen when operator-chaining results in two different sinks in the same topology being chained into a task, and thus into each of its sub-tasks.

      The problem is that TransactionIdsGenerator only takes into account the task name, the subtask index, the number of subtasks, and a couple of other things.  All the attributes are the same between different FlinkKafkaProducer011s within the same sub-task, so they get the same transaction ids and one of them ends up failing.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                pnowojski Piotr Nowojski
                Reporter:
                facboy Christopher Ng
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: