[ https://issues.apache.org/jira/browse/FLINK-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386441#comment-14386441 ]
Paris Carbone commented on FLINK-1798: -------------------------------------- fyi That was the JIRA that got resolved: https://issues.apache.org/jira/browse/FLINK-1686 > Bug in IterateExample while running with parallelism > 1: broker slot is > already occupied > ----------------------------------------------------------------------------------------- > > Key: FLINK-1798 > URL: https://issues.apache.org/jira/browse/FLINK-1798 > Project: Flink > Issue Type: Bug > Components: Streaming > Reporter: Péter Szabó > > Link to the example: > https://github.com/mbalassi/flink/blob/FLINK-1560/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java > Stack Trace: > java.lang.RuntimeException: Could not register the given element, broker slot > is already occupied. > at > org.apache.flink.runtime.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:178) > ~[classes/:na] > at > org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$submitTask(TaskManager.scala:433) > ~[classes/:na] > at > org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$receiveWithLogMessages$1.applyOrElse(TaskManager.scala:238) > ~[classes/:na] > at > scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33) > ~[scala-library-2.10.4.jar:na] > at > scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33) > ~[scala-library-2.10.4.jar:na] > at > scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25) > ~[scala-library-2.10.4.jar:na] > at > org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:37) > ~[classes/:na] > at > org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:30) > ~[classes/:na] > at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118) > ~[scala-library-2.10.4.jar:na] > at > org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:30) > ~[classes/:na] > at akka.actor.Actor$class.aroundReceive(Actor.scala:465) > ~[akka-actor_2.10-2.3.7.jar:na] > at > org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:92) > ~[classes/:na] > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) > [akka-actor_2.10-2.3.7.jar:na] > at akka.actor.ActorCell.invoke(ActorCell.scala:487) > [akka-actor_2.10-2.3.7.jar:na] > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) > [akka-actor_2.10-2.3.7.jar:na] > at akka.dispatch.Mailbox.run(Mailbox.scala:221) > [akka-actor_2.10-2.3.7.jar:na] > at akka.dispatch.Mailbox.exec(Mailbox.scala:231) > [akka-actor_2.10-2.3.7.jar:na] > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > [scala-library-2.10.4.jar:na] > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > [scala-library-2.10.4.jar:na] > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > [scala-library-2.10.4.jar:na] > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > [scala-library-2.10.4.jar:na] > Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Could not > register the given element, broker slot is already occupied. > at > org.apache.flink.streaming.api.streamvertex.StreamIterationHead.setInputsOutputs(StreamIterationHead.java:64) > ~[classes/:na] > at > org.apache.flink.streaming.api.streamvertex.StreamVertex.registerInputOutput(StreamVertex.java:86) > ~[classes/:na] > at > org.apache.flink.runtime.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:175) > ~[classes/:na] > ... 20 common frames omitted > Caused by: java.lang.RuntimeException: Could not register the given element, > broker slot is already occupied. > at > org.apache.flink.runtime.iterative.concurrent.Broker.handIn(Broker.java:39) > ~[classes/:na] > at > org.apache.flink.streaming.api.streamvertex.StreamIterationHead.setInputsOutputs(StreamIterationHead.java:62) > ~[classes/:na] > ... 22 common frames omitted -- This message was sent by Atlassian JIRA (v6.3.4#6332)