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)

Reply via email to