TaskExecutor : Establish JobManager connection
>>>> for job 4f1932f75aafb97028fdbf8cd165ee9d.
>>>> 2020-05-04 18:17:58.035 WARN 23516 --- [lt-dispatcher-5]
>>>> o.a.f.r.h.n.e.EmbeddedLeaderService : Error notifying leader listener
>>>> about
d165ee9d.
>>> 2020-05-04 18:17:58.035 WARN 23516 --- [lt-dispatcher-5]
>>> o.a.f.r.h.n.e.EmbeddedLeaderService : Error notifying leader listener
>>> about new leader
>>>
>>> java.lang.IllegalStateException: The RPC connection is already closed
>&g
cutor : Establish JobManager connection
>> for job 4f1932f75aafb97028fdbf8cd165ee9d.
>> 2020-05-04 18:17:58.035 WARN 23516 --- [lt-dispatcher-5]
>> o.a.f.r.h.n.e.EmbeddedLeaderService : Error notifying leader listener
>> about new leader
>>
>> java.lang.IllegalS
Service : Error notifying leader listener
> about new leader
>
> java.lang.IllegalStateException: The RPC connection is already closed
> at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
> ~[flink-core-1.7.1.jar:1.7.1]
> at
> org.apache.flink.run
java.lang.IllegalStateException: The RPC connection is already closed
at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
~[flink-core-1.7.1.jar:1.7.1]
at
org.apache.flink.runtime.registration.RegisteredRpcConnection.start(RegisteredRpcConnection.java:91)
~[flink-runtime_2.11-1.7.1.jar
