You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/20 11:57:00 UTC

[jira] [Created] (FLINK-30462) DefaultMultipleComponentLeaderElectionService saves wrong leader session ID

Matthias Pohl created FLINK-30462:
-------------------------------------

             Summary: DefaultMultipleComponentLeaderElectionService saves wrong leader session ID
                 Key: FLINK-30462
                 URL: https://issues.apache.org/jira/browse/FLINK-30462
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 1.15.3, 1.16.0, 1.17.0
            Reporter: Matthias Pohl


We save a UUID in [DefaultMultipleComponentLeaderElectionService:195|https://github.com/apache/flink/blob/0290715a57b8d243586ab747b0cd2416c8081012/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultMultipleComponentLeaderElectionService.java#L195] but use a different one for granting the leadership to each of the components (see [DefaultMultipleComponentLeaderElectionService:199|https://github.com/apache/flink/blob/0290715a57b8d243586ab747b0cd2416c8081012/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultMultipleComponentLeaderElectionService.java#L199]).



--
This message was sent by Atlassian Jira
(v8.20.10#820010)