[
https://issues.apache.org/jira/browse/FLINK-8754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8754.
----------------------------------
Resolution: Fixed
Fixed via 461d66eb44307afe22464fbbb2f22dacd8aa96d8
> 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
> Assignee: Gary Yao
> Priority: Blocker
> Labels: flip-6
> Fix For: 1.5.0
>
>
> Taskmanager info cannot be fetched reliably through REST API.
> *Steps to reproduce*
> # Start flink on a cluster (519639c64039563ac4f2a875a8cfa630b25e4e8b)
> #
> {code:java}
> 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)
