You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Muhammad Haseeb Javed <11...@seecs.edu.pk> on 2016/11/19 02:59:59 UTC

Error while running Yahoo Streaming Benchmarks on a single machine

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 ?

Re: Error while running Yahoo Streaming Benchmarks on a single machine

Posted by Robert Metzger <rm...@apache.org>.

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 <
11besemjaved@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 ?
>