You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/10/24 04:16:00 UTC

[jira] [Updated] (BEAM-5848) Flink synthetic source with forward stream causes job failure

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

Thomas Weise updated BEAM-5848:
-------------------------------
    Summary: Flink synthetic source with forward stream causes job failure  (was: Sending empty byte arrays through forward stream causes Flink job failure)

> Flink synthetic source with forward stream causes 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)