Hey guys, I am writing a job which involves creating many different sources to read data from (in this case 80 sources wiht the parallelism of 8 each, running locally on my mac). I cannot create less unfortunately.
The problem is that the job fails while deploying the tasks with the following exception: java.lang.Exception: Failed to deploy the task to slot SimpleSlot (1)(63) - eea7250ab5b368693e3c4f14fb94f86d @ localhost - 8 slots - URL: akka://flink/user/taskmanager_1 - ALLOCATED/ALIVE: Response was not of type Acknowledge at org.apache.flink.runtime.executiongraph.Execution$2.onComplete(Execution.java:392) at akka.dispatch.OnComplete.internal(Future.scala:247) at akka.dispatch.OnComplete.internal(Future.scala:244) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:174) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:171) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) at scala.concurrent.impl.ExecutionContextImpl$anon$3.exec(ExecutionContextImpl.scala:107) 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) Any idea what might cause this? Cheers, Gyula
