[jira] [Created] (FLINK-8754) TaskManagerInfo is not serializable

["Gary Yao (JIRA)" <ji...@apache.org>]

Gary Yao created FLINK-8754:
-------------------------------

             Summary: TaskManagerInfo is not serializable
                 Key: FLINK-8754
                 URL: https://issues.apache.org/jira/browse/FLINK-8754
             Project: Flink
          Issue Type: Bug
          Components: Distributed Coordination
    Affects Versions: 1.5.0
            Reporter: Gary Yao
             Fix For: 1.5.0


Taskmanager info cannot be fetched reliably through REST API.

*Steps to reproduce*
# Start flink on a cluster
# {code}curl host:port/taskmanagers{code}
# Search for stacktrace in taskmanager log
{noformat}
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)
{noformat}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)