flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Error while running Yahoo Streaming Benchmarks on a single machine
Date Wed, 23 Nov 2016 16:58:01 GMT
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 ?
>

Mime
View raw message