Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-1098166517]
- 10/08/2016 21:19:22 Job execution switched to status RUNNING.
- 10/08/2016 21:19:22 Source: Collection Source(1/1) switched to SCHEDULED
- 10/08/2016 21:19:22 Job execution switched to status FAILING.
- org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Not enough free slots available to run the job. You can decrease the operator parallelism or increase the number of slots per TaskManager in the configuration. Task to schedule: < Attempt #0 (Source: Collection Source (1/1)) @ (unassigned) - [SCHEDULED] > with groupID < 24958149568b589d8136ac5d480d8e13 > in sharing group < SlotSharingGroup [24958149568b589d8136ac5d480d8e13, a8b260896df7e38aabb84b466b78c4e6, 6e6d1d2026f920d577370260b646b3a3] >. Resources available to scheduler: Number of instances=0, total number of slots=0, available slots=0
- at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleTask(Scheduler.java:256)
- at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleImmediately(Scheduler.java:131)
- at org.apache.flink.runtime.executiongraph.Execution.scheduleForExecution(Execution.java:306)
- at org.apache.flink.runtime.executiongraph.ExecutionVertex.scheduleForExecution(ExecutionVertex.java:454)
- at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.scheduleAll(ExecutionJobVertex.java:326)
- at org.apache.flink.runtime.executiongraph.ExecutionGraph.scheduleForExecution(ExecutionGraph.java:741)
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply$mcV$sp(JobManager.scala:1332)
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
- 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)
- 10/08/2016 21:19:22 Source: Collection Source(1/1) switched to CANCELED
- 10/08/2016 21:19:22 Flat Map(1/4) switched to CANCELED
- 10/08/2016 21:19:22 Flat Map(2/4) switched to CANCELED
- 10/08/2016 21:19:22 Flat Map(3/4) switched to CANCELED
- 10/08/2016 21:19:22 Flat Map(4/4) switched to CANCELED
- 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(1/4) switched to CANCELED
- 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(2/4) switched to CANCELED
- 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(3/4) switched to CANCELED
- 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(4/4) switched to CANCELED
- 10/08/2016 21:19:22 Job execution switched to status FAILED.
- Oct 08, 2016 9:19:22 PM getevents.TestApp$1 handleMessage
- SEVERE: null
- org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply$mcV$sp(JobManager.scala:822)
- 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.pollAndExecAll(ForkJoinPool.java:1253)
- at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
- at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
- at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
- Caused by: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Not enough free slots available to run the job. You can decrease the operator parallelism or increase the number of slots per TaskManager in the configuration. Task to schedule: < Attempt #0 (Source: Collection Source (1/1)) @ (unassigned) - [SCHEDULED] > with groupID < 24958149568b589d8136ac5d480d8e13 > in sharing group < SlotSharingGroup [24958149568b589d8136ac5d480d8e13, a8b260896df7e38aabb84b466b78c4e6, 6e6d1d2026f920d577370260b646b3a3] >. Resources available to scheduler: Number of instances=0, total number of slots=0, available slots=0
- at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleTask(Scheduler.java:256)
- at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleImmediately(Scheduler.java:131)
- at org.apache.flink.runtime.executiongraph.Execution.scheduleForExecution(Execution.java:306)
- at org.apache.flink.runtime.executiongraph.ExecutionVertex.scheduleForExecution(ExecutionVertex.java:454)
- at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.scheduleAll(ExecutionJobVertex.java:326)
- at org.apache.flink.runtime.executiongraph.ExecutionGraph.scheduleForExecution(ExecutionGraph.java:741)
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply$mcV$sp(JobManager.scala:1332)
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
- at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
- 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)
- ... 2 more
Advertisement
Add Comment
Please, Sign In to add comment