Guest User

Untitled

a guest
Oct 8th, 2016
146
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 6.68 KB | None | 0 0
  1. Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-1098166517]
  2. 10/08/2016 21:19:22 Job execution switched to status RUNNING.
  3. 10/08/2016 21:19:22 Source: Collection Source(1/1) switched to SCHEDULED
  4. 10/08/2016 21:19:22 Job execution switched to status FAILING.
  5. 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
  6. at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleTask(Scheduler.java:256)
  7. at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleImmediately(Scheduler.java:131)
  8. at org.apache.flink.runtime.executiongraph.Execution.scheduleForExecution(Execution.java:306)
  9. at org.apache.flink.runtime.executiongraph.ExecutionVertex.scheduleForExecution(ExecutionVertex.java:454)
  10. at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.scheduleAll(ExecutionJobVertex.java:326)
  11. at org.apache.flink.runtime.executiongraph.ExecutionGraph.scheduleForExecution(ExecutionGraph.java:741)
  12. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply$mcV$sp(JobManager.scala:1332)
  13. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
  14. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
  15. at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
  16. at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
  17. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
  18. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
  19. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  20. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  21. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  22. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  23. 10/08/2016 21:19:22 Source: Collection Source(1/1) switched to CANCELED
  24. 10/08/2016 21:19:22 Flat Map(1/4) switched to CANCELED
  25. 10/08/2016 21:19:22 Flat Map(2/4) switched to CANCELED
  26. 10/08/2016 21:19:22 Flat Map(3/4) switched to CANCELED
  27. 10/08/2016 21:19:22 Flat Map(4/4) switched to CANCELED
  28. 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(1/4) switched to CANCELED
  29. 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(2/4) switched to CANCELED
  30. 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(3/4) switched to CANCELED
  31. 10/08/2016 21:19:22 Keyed Aggregation -> Sink: Unnamed(4/4) switched to CANCELED
  32. 10/08/2016 21:19:22 Job execution switched to status FAILED.
  33. Oct 08, 2016 9:19:22 PM getevents.TestApp$1 handleMessage
  34. SEVERE: null
  35. org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
  36. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply$mcV$sp(JobManager.scala:822)
  37. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:768)
  38. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:768)
  39. at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
  40. at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
  41. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
  42. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
  43. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  44. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
  45. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
  46. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  47. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  48. 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
  49. at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleTask(Scheduler.java:256)
  50. at org.apache.flink.runtime.jobmanager.scheduler.Scheduler.scheduleImmediately(Scheduler.java:131)
  51. at org.apache.flink.runtime.executiongraph.Execution.scheduleForExecution(Execution.java:306)
  52. at org.apache.flink.runtime.executiongraph.ExecutionVertex.scheduleForExecution(ExecutionVertex.java:454)
  53. at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.scheduleAll(ExecutionJobVertex.java:326)
  54. at org.apache.flink.runtime.executiongraph.ExecutionGraph.scheduleForExecution(ExecutionGraph.java:741)
  55. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply$mcV$sp(JobManager.scala:1332)
  56. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
  57. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply(JobManager.scala:1291)
  58. at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
  59. at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
  60. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
  61. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
  62. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  63. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  64. ... 2 more
Advertisement
Add Comment
Please, Sign In to add comment