Robert Bradshaw created BEAM-5395:
-------------------------------------

             Summary: BeamPython data plane streams data
                 Key: BEAM-5395
                 URL: https://issues.apache.org/jira/browse/BEAM-5395
             Project: Beam
          Issue Type: Bug
          Components: sdk-py-harness
            Reporter: Robert Bradshaw
            Assignee: Robert Bradshaw


Currently the default implementation is to buffer all data for the bundle. 

Experiments were made splitting at arbitrary byte boundaries, but it appears 
that Java requires messages to be split on element boundaries. For now we 
should implement that in Python (even if this means not being able to split up 
large elements among multiple messages). 



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

Reply via email to