[
https://issues.apache.org/jira/browse/FLINK-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó updated FLINK-1798:
-------------------------------
Component/s: Streaming
> 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)
