[
https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485085#comment-14485085
]
ASF GitHub Bot commented on FLINK-1813:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/577#issuecomment-90882862
Looks good to me
> Barrier broadcast sometimes causes illegal state exception in source
> RecordWriter
> ---------------------------------------------------------------------------------
>
> Key: FLINK-1813
> URL: https://issues.apache.org/jira/browse/FLINK-1813
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Reporter: Gyula Fora
> Assignee: Gyula Fora
>
> The StreamCheckPointingITCase sometimes fails on an illegal state exception
> thrown when trying to broadcast barrier from the sources. I think this is
> caused by sending a barrier when the source is not running any more.
> The exception:
> Exception in thread "Thread-341" java.lang.RuntimeException:
> java.lang.IllegalStateException: Partition already finished.
> at
> org.apache.flink.streaming.api.streamvertex.StreamVertex.actOnBarrier(StreamVertex.java:300)
> at
> org.apache.flink.streaming.api.streamvertex.StreamVertex.broadcastBarrierFromSource(StreamVertex.java:105)
> at
> org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$receiveWithLogMessages$1$$anon$4.run(TaskManager.scala:386)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.IllegalStateException: Partition already finished.
> at
> org.apache.flink.shaded.com.google.common.base.Preconditions.checkState(Preconditions.java:173)
> at
> org.apache.flink.runtime.io.network.partition.ResultPartition.checkInProduceState(ResultPartition.java:388)
> at
> org.apache.flink.runtime.io.network.partition.ResultPartition.add(ResultPartition.java:221)
> at
> org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter.writeEvent(ResultPartitionWriter.java:78)
> at
> org.apache.flink.runtime.io.network.api.writer.RecordWriter.broadcastEvent(RecordWriter.java:117)
> at
> org.apache.flink.streaming.api.collector.StreamOutput.broadcastEvent(StreamOutput.java:92)
> at
> org.apache.flink.streaming.api.streamvertex.OutputHandler.broadcastBarrier(OutputHandler.java:94)
> at
> org.apache.flink.streaming.api.streamvertex.StreamVertex.actOnBarrier(StreamVertex.java:294)
> ... 3 more
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
