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

New source interface cannot unregister unregistered source

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.12.0, 1.11.2
    • Fix Version/s: 1.12.0, 1.11.3
    • Component/s: Connectors / Common
    • Labels:
      None

      Description

      When a source subtask fails before the respective reader is registered in SourceCoordinatorContext, unregistering fails as it explicitly verifies that the reader has been registered before.

      The solution is to drop the assumption that all readers are registered when cleaning up subtasks.

        Attachments

          Activity

            People

            • Assignee:
              AHeise Arvid Heise
              Reporter:
              AHeise Arvid Heise
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: