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. invokeInteractiveModeForExecut ion(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 ?
Free forum by Nabble | Edit this page |