flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fabian Hueske (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version
Date Thu, 15 Sep 2016 19:17:21 GMT

     [ https://issues.apache.org/jira/browse/FLINK-4515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Fabian Hueske updated FLINK-4515:
---------------------------------
    Component/s: JobManager

> org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1
released version
> -------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-4515
>                 URL: https://issues.apache.org/jira/browse/FLINK-4515
>             Project: Flink
>          Issue Type: Bug
>          Components: JobManager
>    Affects Versions: 1.2.0
>            Reporter: Nagarjun Guraja
>
> Current org.apache.flink.runtime.jobmanager.JobInfo in the 1.2 trunk is not backwards
compatible which breaks job recorvery while upgrading to latest flink build from 1.1 release
> 2016-08-26 13:39:56,618 INFO  org.apache.flink.runtime.jobmanager.JobManager        
       - Attempting to recover all jobs.
> 2016-08-26 13:39:57,225 ERROR org.apache.flink.runtime.jobmanager.JobManager        
       - Fatal error: Failed to recover jobs.
> java.io.InvalidClassException: org.apache.flink.runtime.jobmanager.JobInfo; local class
incompatible: stream classdesc serialVersionUID = 4102282956967236682, local class serialVersionUID
= -2377916285980374169
>     at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:616)
>     at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1623)
>     at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518)
>     at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774)
>     at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
>     at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
>     at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
>     at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
>     at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
>     at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
>     at org.apache.flink.runtime.state.filesystem.FileSerializableStateHandle.getState(FileSerializableStateHandle.java:58)
>     at org.apache.flink.runtime.state.filesystem.FileSerializableStateHandle.getState(FileSerializableStateHandle.java:35)
>     at org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.recoverJobGraphs(ZooKeeperSubmittedJobGraphStore.java:173)
>     at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$2$$anonfun$apply$mcV$sp$2.apply$mcV$sp(JobManager.scala:543)
>     at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$2$$anonfun$apply$mcV$sp$2.apply(JobManager.scala:539)
>     at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$2$$anonfun$apply$mcV$sp$2.apply(JobManager.scala:539)
>     at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58)
>     at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$2.apply$mcV$sp(JobManager.scala:539)
>     at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$2.apply(JobManager.scala:535)
>     at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$2.apply(JobManager.scala:535)
>     at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
>     at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
>     at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
>     at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
>     at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>     at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
>     at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
>     at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>     at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)



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

Mime
View raw message