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 02bf081 [BEAM-10704] Fix Py3 incompatibility in stager.py. #12579
add 55874cc [BEAM-10691] Use FlinkStateInternals#addWatermarkHoldUsage
for timer output timestamp
add b5846c6 Merge pull request #12551: [BEAM-10691] Use
FlinkStateInternals#addWatermarkHoldUsage for timer output timestamp
No new revisions were added by this update.
Summary of changes:
.../wrappers/streaming/DoFnOperator.java | 33 ++++------------------
.../streaming/state/FlinkStateInternals.java | 21 +++++---------
.../wrappers/streaming/DoFnOperatorTest.java | 2 +-
.../wrappers/streaming/WindowDoFnOperatorTest.java | 2 --
4 files changed, 13 insertions(+), 45 deletions(-)
