This is an automated email from the ASF dual-hosted git repository.
goenka pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4e9d121 Merge pull request #7796 from tvalentyn/patch-37
new bef135b Improve visibility of large key commits in
StreamingDataflowWorker by reporting an error and adding a counter for the
maximum key commit size.
new 1fed9bd Merge branch 'max_commit_bytes' of
https://github.com/scwhittle/beam into max_commit_bytes
new 685fc05 setMaxWorkItemCommitBytes must be only called for Streaming
Engine, not for Appliance.
new d493c1c Added test for streaming engine.
new 3e3914d Applied spotless.
new 4934520 Merge pull request #7816 from drieber/max_commit_bytes
The 20125 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../dataflow/worker/DataflowSystemMetrics.java | 1 +
.../dataflow/worker/StreamingDataflowWorker.java | 109 ++++++++++++------
.../worker/StreamingDataflowWorkerTest.java | 122 +++++++++++++++++++++
3 files changed, 201 insertions(+), 31 deletions(-)
