You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/10 09:55:35 UTC
[jira] [Commented] (FLINK-1496) Events at unitialized input
channels are lost
[ https://issues.apache.org/jira/browse/FLINK-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14313849#comment-14313849 ]
ASF GitHub Bot commented on FLINK-1496:
---------------------------------------
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/380
[FLINK-1496] [distributed runtime] Fix loss of events at unitialized input channels
Related [discussion](http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Events-not-received-td3699.html).
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/uce/incubator-flink flink-1496-lost
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/380.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 #380
----
commit d73585c346e7f10b7157305d640b740e786557b9
Author: Ufuk Celebi <uc...@apache.org>
Date: 2015-02-09T16:17:19Z
[FLINK-1496] [distributed runtime] Fix loss of events at unitialized input channels
----
> Events at unitialized input channels are lost
> ---------------------------------------------
>
> Key: FLINK-1496
> URL: https://issues.apache.org/jira/browse/FLINK-1496
> Project: Flink
> Issue Type: Bug
> Components: Distributed Runtime
> Affects Versions: master
> Reporter: Ufuk Celebi
>
> If a program sends an event backwards to the producer task, it might happen that some of it input channels have not been initialized yet (UnknownInputChannel). In that case, the events are lost and will never be received at the producer.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)