[ https://issues.apache.org/jira/browse/FLINK-16562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-16562: ----------------------------------- Labels: stale-assigned (was: ) > Handle JobManager termination future in place > --------------------------------------------- > > Key: FLINK-16562 > URL: https://issues.apache.org/jira/browse/FLINK-16562 > Project: Flink > Issue Type: Improvement > Components: Runtime / Coordination > Reporter: Zili Chen > Assignee: Zili Chen > Priority: Major > Labels: stale-assigned > Fix For: 1.13.0 > > > After FLINK-11843 {{Dispatcher}} becomes a {{PermanentlyFencedRpcEndpoint}} > and will be created as different instance in difference leader epoch. Thus, > we don't have {{jobManagerTerminationFutures}} crosses multiple leader epoch > that should be handled. Given the truth, we can remove > {{jobManagerTerminationFutures}} field in {{Dispatcher}} and handle those > futures in place, which will simplify the code and helps on further > refactoring. > CC [~trohrmann] > I will create a branch later this week. -- This message was sent by Atlassian Jira (v8.3.4#803005)