[ https://issues.apache.org/jira/browse/FLINK-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Paris Carbone closed FLINK-1686. -------------------------------- Resolution: Fixed > Streaming iteration heads cannot be instantiated > ------------------------------------------------ > > Key: FLINK-1686 > URL: https://issues.apache.org/jira/browse/FLINK-1686 > Project: Flink > Issue Type: Bug > Components: Streaming > Reporter: Paris Carbone > Priority: Critical > > It looks that streaming jobs with iterations and dop > 1 do not work > currently. From what I see, when the TaskManager tries to instantiate a new > RuntimeEnvironment for the iteration head tasks it fails since the following > exception is being thrown: > java.lang.Exception: Failed to deploy the task Map (2/8) - execution #0 to > slot SimpleSlot (0)(1) - 0e39fcabcab3e8543cc2d8320f9de783 - ALLOCATED/ALIVE: > java.lang.Exception: Error setting up runtime environment: > java.lang.RuntimeException: Could not register the given element, broker slot > is already occupied. > at > org.apache.flink.runtime.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:174) > at > org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$submitTask(TaskManager.scala:432) > ..... > ..... > 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) > at > org.apache.flink.streaming.api.streamvertex.StreamVertex.registerInputOutput(StreamVertex.java:86) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:171) > ... 20 more > 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) > at > org.apache.flink.streaming.api.streamvertex.StreamIterationHead.setInputsOutputs(StreamIterationHead.java:62) > The IterateTest passed since it is using a dop of 1 but for higher > parallelism it fails. Also, the IterateExample fails as well if you try to > run it. > I will debug this once I find some time so any ideas of what could possible > cause this are more than welcome. -- This message was sent by Atlassian JIRA (v6.3.4#6332)