Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-16373

EmbeddedLeaderService: IllegalStateException: The RPC connection is already closed

    XMLWordPrintableJSON

Details

    Description

      In our CI system, I see a lot of these error messages:

      09:52:41,108 [flink-akka.actor.default-dispatcher-2] INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for fd36e49b9105838fc7fb8fff442ade28.
      09:52:41,108 [mini-cluster-io-thread-14] WARN  org.apache.flink.runtime.highavailability.nonha.embedded.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)
      	at org.apache.flink.runtime.registration.RegisteredRpcConnection.start(RegisteredRpcConnection.java:90)
      	at org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener.notifyLeaderAddress(JobLeaderService.java:334)
      	at org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService$NotifyOfLeaderCall.run(EmbeddedLeaderService.java:515)
      	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      	at java.lang.Thread.run(Thread.java:748)
      09:52:41,109 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
      

      Example cases

      Attachments

        1. 20200302.17.tar.gz
          9.03 MB
          Robert Metzger
        2. 20200302.19.tar.gz
          2.38 MB
          Robert Metzger

        Issue Links

          Activity

            People

              trohrmann Till Rohrmann
              rmetzger Robert Metzger
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m