This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from a7b24f3d577 Revert "Revert "[Experimental] Use zstd compression in
Docker ...
add fd93d795124 [Spark] Retain the last watermark of a source with no
update in the batch (#39823)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Java_PVR_Spark3_Streaming.json | 2 +-
...beam_PostCommit_Java_ValidatesRunner_Spark.json | 2 +-
CHANGES.md | 1 +
.../spark/stateful/SparkTimerInternals.java | 15 ++---
.../runners/spark/util/GlobalWatermarkHolder.java | 22 +++++--
.../runners/spark/GlobalWatermarkHolderTest.java | 72 ++++++++++++++++++++++
.../translation/streaming/CreateStreamTest.java | 4 +-
.../StatefulStreamingParDoEvaluatorTest.java | 6 +-
8 files changed, 105 insertions(+), 19 deletions(-)
