https://issues.apache.org/jira/browse/FLINK-16373
On Mon, May 4, 2020 at 9:37 PM Manish G <manish.c.ghildi...@gmail.com> wrote: > I found another similar issue: > > > On Mon, May 4, 2020 at 9:28 PM Steven Wu <stevenz...@gmail.com> wrote: > >> Manish, might be related to this bug, which is fixed in 1.10.1. >> >> >> https://issues.apache.org/jira/browse/FLINK-14316?focusedCommentId=16946580&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-16946580 >> >> On Mon, May 4, 2020 at 5:52 AM Manish G <manish.c.ghildi...@gmail.com> >> wrote: >> >>> 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? >>> >>
