1.美图

2.背景

不知道什么原因导致了这个问题，先记录一下

(2020-04 10 18:12:11]1 [INFO] [org. apache.flink runtime taskexecutorJobleaderService:193 Add jöb 616d9690eoascosoeoeoero
[2020-04- 10 18:12:111 [WARN] [org.apache.flink runtime. highavailability nonha embedded. Embeddedl eaderService:516] Error notifying leader istener about new leader
java.lang.illegalStateException: The RPC connection is already closed
	at org apache.flink util.Preconditions.checkState(Preconditions.java:195)
	at org.apache.flink.runtime.registration.RegisteredRpc onnection.start(RegisteredRpcConnection.java:90)
	at org.apache flink.runtime.taskexecutorJob eaderService$JobManagerLeaderListener.notify eaderAddress(Job eaderServicejava:334)
	at org apache. flink runtime. highavailability.nonha.embedded Embeddedl eaderService$NotifyOf eaderC allun(Embedded eaderService.java:513)
	at java.util.concurrent. ompletableFuture$AsyncRun.run(CompletableFuture.java:1626)
	at java.util.concurrent.ThreadPoolExecutor.runWorkerhreadPoolExecutor.java:1149)
	at java.util.concurrentThreadPoolExecutorSWork run(ThreadPoolExecutor.java:624)