You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ja...@apache.org on 2020/08/14 17:04:28 UTC

[beam] branch master updated (02bf081 -> b5846c6)

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