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(-)