Péter Szabó created FLINK-1798:
----------------------------------
Summary: 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
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)
