Thomas Weise created BEAM-5848:
----------------------------------
Summary: 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
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)