[jira] [Commented] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized

["Till Rohrmann (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372874#comment-15372874 ] 

Till Rohrmann commented on FLINK-4006:
--------------------------------------

Thanks for spotting this issue [~bowen.zheng]. I think you're right that we should null the restart strategy in the {{prepareForArchiving}} method.

> ExecutionGraph.restartStrategy field can't be serialized
> --------------------------------------------------------
>
>                 Key: FLINK-4006
>                 URL: https://issues.apache.org/jira/browse/FLINK-4006
>             Project: Flink
>          Issue Type: Bug
>            Reporter: ZhengBowen
>         Attachments: FLINK-4006.patch
>
>
> Exception is following
> ```
> java.io.NotSerializableException: org.apache.flink.runtime.executiongraph.restart.NoRestartStrategy
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183)
> 	at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1547)
> 	at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1508)
> 	at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1431)
> 	at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1177)
> 	at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347)
> 	at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:300)
> 	at com.rds.computing.rc.meta.MetaJobInfo.readFrom(MetaJobInfo.java:94)
> 	at org.apache.flink.runtime.webmonitor.DatabaseArchivist$DataBaseHashMap.put(DatabaseArchivist.java:209)
> 	at org.apache.flink.runtime.webmonitor.DatabaseArchivist.handleMessage(DatabaseArchivist.java:64)
> 	at org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:97)
> 	at org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:68)
> 	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
> 	at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
> 	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
> 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
> 	at akka.actor.ActorCell.invoke(ActorCell.scala:487)
> 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
> 	at akka.dispatch.Mailbox.run(Mailbox.scala:221)
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> 	at java.lang.Thread.run(Thread.java:745)
> ```
> I think you should set null for restartStrategy in prepareForArchiving() function.
> Following attachments is my patch



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)