tree 01f806b057c2c3be75876b6b6bb5beeafddb4b34
parent 037687c2ea1f1b81cc77b14c11ad529b30da4db5
author Stephan Ewen <sewen@apache.org> 1626179792 +0200
committer Stephan Ewen <sewen@apache.org> 1626214067 +0200

[FLINK-22545][coordination] Fix check during creation of Source Coordinator thread.

The check was meant as a safeguard to prevent re-instantiation after fatal errors killed a previous thread.
But the check was susceptible to thread termination due to idleness in the executor.

This updates the check to only fail if there is in fact an instantiation next to a running thread, or after a
previously crashed thread.