Thomas Weise created BEAM-5760:
----------------------------------
Summary: Portable Flink support for maxBundleSize/maxBundleMillis
Key: BEAM-5760
URL: https://issues.apache.org/jira/browse/BEAM-5760
Project: Beam
Issue Type: Improvement
Components: runner-flink
Affects Versions: 2.8.0
Reporter: Thomas Weise
Fix For: 2.9.0
The portable runner needs to support larger bundles in streaming mode.
Currently every element is a separate bundle, which is very inefficient due to
the per bundle SDK worker overhead. The old Java SDK runner already supports
these parameters.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)