Hi, I have set up flink and kafka locally. When I start my flink program(configured ot read messages from kafka topic), I get error as:
2020-05-04 18:17:58.035 INFO 23516 --- [lt-dispatcher-2] o.a.f.r.taskexecutor.JobLeaderService : Successful registration at job manager akka://flink/user/jobmanager_1 for job 4f1932f75aafb97028fdbf8cd165ee9d. 2020-05-04 18:17:58.035 INFO 23516 --- [lt-dispatcher-4] o.a.f.r.taskexecutor.JobLeaderService : Successful registration at job manager akka://flink/user/jobmanager_1 for job 4f1932f75aafb97028fdbf8cd165ee9d. 2020-05-04 18:17:58.035 INFO 23516 --- [lt-dispatcher-4] o.a.f.runtime.taskexecutor.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 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.runtime.registration.RegisteredRpcConnection.start(RegisteredRpcConnection.java:91) ~[flink-runtime_2.11-1.7.1.jar:1.7.1] What can be the root cause for this?
