[jira] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

[Giuliano Caliari (JIRA)]

Title: Message Title
 
 
 
 
 
 
 
 
 
 
  
 
 Giuliano Caliari closed an issue as Workaround 
 
 
 
 
 
 
 
 
 
 

 
 
 
 
 
 
 
 Flink /  FLINK-5633 
 
 
 
  ClassCastException: X cannot be cast to X when re-submitting a job.  
 
 
 
 
 
 
 
 
 

Change By:
 
 Giuliano Caliari 
 
 
 

Resolution:
 
 Workaround 
 
 
 

Status:
 
 Open Closed 
 
 
 
 
 
 
 
 
 
 
 
 

 
 Add Comment 
 
 
 
 
 
 
 
 
 
 

 
 
 
 
 
 
 
 
 
 

 This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d) 
 
 
 
 
  
 
 
 
 
 
 
 
 
   

[jira] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

[Giuliano Caliari (JIRA)]

Title: Message Title
 
 
 
 
 
 
 
 
 
 
  
 
 Giuliano Caliari commented on  FLINK-5633 
 
 
 
 
 
 
 
 
 
 

 
 
 
 
 
 
 
  Re: ClassCastException: X cannot be cast to X when re-submitting a job.  
 
 
 
 
 
 
 
 
 
 
Hey Stephan Ewen, I've confirmed that Yuri's solution also works for us. Closing it.  
 
 
 
 
 
 
 
 
 
 
 
 

 
 Add Comment 
 
 
 
 
 
 
 
 
 
 

 
 
 
 
 
 
 
 
 
 

 This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d) 
 
 
 
 
  
 
 
 
 
 
 
 
 
   

[jira] [Created] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

[Giuliano Caliari (JIRA)]

Giuliano Caliari created FLINK-5633:
---

 Summary: ClassCastException: X cannot be cast to X when 
re-submitting a job.
 Key: FLINK-5633
 URL: https://issues.apache.org/jira/browse/FLINK-5633
 Project: Flink
  Issue Type: Bug
  Components: Job-Submission, YARN
Affects Versions: 1.1.4
Reporter: Giuliano Caliari
Priority: Minor


I’m running a job on my local cluster and the first time I submit the job 
everything works but whenever I cancel and re-submit the same job it fails with:

{quote}
org.apache.flink.client.program.ProgramInvocationException: The program 
execution failed: Job execution failed.

at 
org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:427)

at 
org.apache.flink.client.program.StandaloneClusterClient.submitJob(StandaloneClusterClient.java:101)

at 
org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:400)

at 
org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:66)

at 
org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:634)

at au.com.my.package.pTraitor.OneTrait.execute(Traitor.scala:147)

at 
au.com.my.package.pTraitor.TraitorAppOneTrait$.delayedEndpoint$au$com$my$package$pTraitor$TraitorAppOneTrait$1(TraitorApp.scala:22)

at 
au.com.my.package.pTraitor.TraitorAppOneTrait$delayedInit$body.apply(TraitorApp.scala:21)

at scala.Function0$class.apply$mcV$sp(Function0.scala:34)

at 
scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)

at scala.App$$anonfun$main$1.apply(App.scala:76)

at scala.App$$anonfun$main$1.apply(App.scala:76)

at scala.collection.immutable.List.foreach(List.scala:381)

at 
scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)

at scala.App$class.main(App.scala:76)

at 
au.com.my.package.pTraitor.TraitorAppOneTrait$.main(TraitorApp.scala:21)

at au.com.my.package.pTraitor.TraitorAppOneTrait.main(TraitorApp.scala)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at 
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528)

at 
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419)

at 
org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:339)

at 
org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:831)

at org.apache.flink.client.CliFrontend.run(CliFrontend.java:256)

at 
org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1073)

at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1120)

at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1117)

at 
org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:29)

at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1116)

Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution 
failed.

at 
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$6.apply$mcV$sp(JobManager.scala:900)

at 
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$6.apply(JobManager.scala:843)

at 
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$6.apply(JobManager.scala:843)

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:40)

at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)

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.lang.RuntimeException: Could not forward element to next 
operator

at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:415)

at