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