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

ConcurrentModificationException in WatermarkCallbackService

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.3.0
    • Fix Version/s: 1.3.0
    • Component/s: DataStream API
    • Labels:
      None

      Description

      Currently, if an attempt is made to call InternalWatermarkCallbackService.unregisterKeyFromWatermarkCallback() from within the OnWatermarkCallback, a ConcurrentModificationException is thrown. The reason is that the invokeOnWatermarkCallback iterates over the list of keys and calls the callback for each one of them.

      To fix this, the deleted keys are put into a separate list, and the deletion happens after the iteration over all keys has finished.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                kkl0u Kostas Kloudas
                Reporter:
                kkl0u Kostas Kloudas
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: