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)