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

Posted to commits@beam.apache.org by re...@apache.org on 2021/04/28 19:30:00 UTC

[beam] branch master updated (b1a67ef -> faf1542)

This is an automated email from the ASF dual-hosted git repository.

reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from b1a67ef  Merge pull request #14670: [BEAM-12243] TPC-DS: use SQL "substring()" instead of "substr()"
     add 331ac5d  [BEAM-12229] StreamingModeExecutionContext invalidated WindmillStateCache keys repeatedly for fused stages with more than one stage.
     add faf1542  Merge pull request #14649: [BEAM-12229] StreamingModeExecutionContext invalidated WindmillStateCache keys  repeatedly for fused stages with more than one stage.

No new revisions were added by this update.

Summary of changes:
 .../dataflow/worker/StreamingDataflowWorker.java   |   2 +-
 .../worker/StreamingModeExecutionContext.java      |  27 +-
 .../dataflow/worker/WindmillStateCache.java        |  41 +--
 .../worker/StreamingDataflowWorkerTest.java        | 303 +++++++++++++++++++++
 .../dataflow/worker/WindmillStateCacheTest.java    | 133 ++++++---
 .../worker/WindmillStateInternalsTest.java         |   8 +-
 6 files changed, 449 insertions(+), 65 deletions(-)