Error while running Yahoo Streaming Benchmarks on a single machine

Posted by Muhammad Haseeb Javed on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Error-while-running-Yahoo-Streaming-Benchmarks-on-a-single-machine-tp10222.html

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 ?