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

Ephemeral socket address was checkpointed to state and restored back in CollectSinkOperatorCoordinator

    XMLWordPrintableJSON

    Details

      Description

      CollectSinkOperatorCoordinator checkpointed its address field to state and restored back. That field is listener address of CollectSinkFunction. After resetToCheckpoint (eg. global failover}}, address is meaningless. If client request comes before CollectSinkAddressEvent, it will use that meaningless address for connection. In best situation, error happens, and nothing hurts. In bad situation, no one knows where the restored address points to now. 

      cc  Caizhi Weng Kurt Young

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              kezhuw Kezhu Wang
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: