This is an automated email from the ASF dual-hosted git repository.
janl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 080f54a144a [BEAM-13806] Add x-lang BigQuery IO integration test to Go
SDK. (#16818)
add 6e450a92da7 [BEAM-14265] Add watermark hold for all timers
new 7bf822a5419 Merge pull request #17809: [BEAM-14265] Add watermark hold
for all timers
The 1 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:
.../beam/runners/core/StatefulDoFnRunner.java | 21 +---
.../wrappers/streaming/DoFnOperator.java | 109 ++++++---------------
.../streaming/state/FlinkStateInternals.java | 18 +++-
.../wrappers/streaming/DoFnOperatorTest.java | 28 +++---
4 files changed, 58 insertions(+), 118 deletions(-)
