[ https://issues.apache.org/jira/browse/BEAM-5848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Weise resolved BEAM-5848. -------------------------------- Resolution: Fixed Fix Version/s: 2.9.0 > Flink runner 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 > Fix For: 2.9.0 > > Attachments: image-2018-10-23-20-46-58-991.png > > Time Spent: 0.5h > Remaining Estimate: 0h > > 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)