[ 
https://issues.apache.org/jira/browse/BEAM-5848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Thomas Weise updated BEAM-5848:
-------------------------------
    Attachment: image-2018-10-23-20-46-58-991.png

> Sending empty byte arrays through forward stream causes Flink job failure
> -------------------------------------------------------------------------
>
>                 Key: BEAM-5848
>                 URL: https://issues.apache.org/jira/browse/BEAM-5848
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>            Reporter: Thomas Weise
>            Assignee: Thomas Weise
>            Priority: Minor
>         Attachments: image-2018-10-23-20-46-58-991.png
>
>
> Running the synthetic source example (which is generating empty byte arrays) 
> with operator chaining disabled (which is causing said empty byte arrays to 
> be transmitted over forward stream) cause the job to fail after a few seconds.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to