Hi, this is not really a failure. It just means that the job has been cancelled by somebody (using the web interface or the ./bin/flink tool).
On Sat, Nov 19, 2016 at 3:59 AM, Muhammad Haseeb Javed < 11besemja...@seecs.edu.pk> wrote: > I am trying to run the Yahoo Streaming Benchmarks on a single machine > right now. When I run them for Flink I am getting the following error: > > > org.apache.flink.client.program.ProgramInvocationException: The program > execution failed: Job was cancelled. > > at org.apache.flink.client.program.ClusterClient.run( > ClusterClient.java:409) > > at org.apache.flink.client.program.StandaloneClusterClient.submitJob( > StandaloneClusterClient.java:95) > > at org.apache.flink.client.program.ClusterClient.run( > ClusterClient.java:382) > > at org.apache.flink.streaming.api.environment.StreamContextEnvironment. > execute(StreamContextEnvironment.java:68) > > at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment. > execute(StreamExecutionEnvironment.java:1429) > > at flink.benchmark.AdvertisingTopologyNative.main( > AdvertisingTopologyNative.java:89) > > 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:483) > > at org.apache.flink.client.program.PackagedProgram.callMainMethod( > PackagedProgram.java:509) > > at org.apache.flink.client.program.PackagedProgram. > invokeInteractiveModeForExecution(PackagedProgram.java:403) > > at org.apache.flink.client.program.ClusterClient.run( > ClusterClient.java:320) > > at org.apache.flink.client.CliFrontend.executeProgram( > CliFrontend.java:777) > > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:253) > > at org.apache.flink.client.CliFrontend.parseParameters( > CliFrontend.java:1005) > > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1048) > > Caused by: org.apache.flink.runtime.client.JobCancellationException: Job > was cancelled. > > at org.apache.flink.runtime.jobmanager.JobManager$$ > anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply$ > mcV$sp(JobManager.scala:814) > > at org.apache.flink.runtime.jobmanager.JobManager$$ > anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:768) > > at org.apache.flink.runtime.jobmanager.JobManager$$ > anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:768) > > 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. > runTask(ForkJoinPool.java:1339) > > at scala.concurrent.forkjoin.ForkJoinPool.runWorker( > ForkJoinPool.java:1979) > > at scala.concurrent.forkjoin.ForkJoinWorkerThread.run( > ForkJoinWorkerThread.java:107) > > > What do you think might be the issue ? >
