[
https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14484082#comment-14484082
]
ASF GitHub Bot commented on FLINK-1813:
---------------------------------------
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/577
[FLINK-1813] Avoid illegalstate exception when trying to broadcast on
finished operators
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink FLINK-1813
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/577.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #577
----
commit e3810484c6fa71f9c1dac69707c81e44380a2d1c
Author: Gyula Fora <[email protected]>
Date: 2015-04-07T20:17:18Z
[FLINK-1813] Avoid illegalstate exception when trying to broadcast on
finished operators
----
> 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)
