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

TaskManagerInfo is not serializable

    Details

      Description

      Taskmanager info cannot be fetched reliably through REST API.

      Steps to reproduce

      1. Start flink on a cluster (519639c64039563ac4f2a875a8cfa630b25e4e8b)
      2. curl host:port/taskmanagers
      1. Search for stacktrace in taskmanager log
        akka.remote.MessageSerializer$SerializationException: Failed to serialize remote message [class java.util.ArrayList] using serializer [class akka.serialization.JavaSerializer].
             at akka.remote.MessageSerializer$.serialize(MessageSerializer.scala:61)
             at akka.remote.EndpointWriter$$anonfun$serializeMessage$1.apply(Endpoint.scala:889)
             at akka.remote.EndpointWriter$$anonfun$serializeMessage$1.apply(Endpoint.scala:889)
             at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58)
             at akka.remote.EndpointWriter.serializeMessage(Endpoint.scala:888)
             at akka.remote.EndpointWriter.writeSend(Endpoint.scala:780)
             at akka.remote.EndpointWriter$$anonfun$4.applyOrElse(Endpoint.scala:755)
             at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
             at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:446)
             at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
             at akka.actor.ActorCell.invoke(ActorCell.scala:495)
             at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
             at akka.dispatch.Mailbox.run(Mailbox.scala:224)
             at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
             at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
             at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
             at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
             at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
        Caused by: java.io.NotSerializableException: org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerInfo
             at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184)
             at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
             at java.util.ArrayList.writeObject(ArrayList.java:762)
        

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                gjy Gary Yao
                Reporter:
                gjy Gary Yao
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: