This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 7d93ef8e76a Filter classes accepted by TransformUpgrader
deserialization (#40438)
add 6d31e0e0c14 [Java] Fix TextIO gzip split test on Windows (#40078)
add 98286d1c7ac [Spark 4] Filter late data against the key's previous
watermark in the streaming stateful ParDo (#40447)
add 58dc2a472d6 [DebeziumIO] Update Debezium documentation link to version
3.5 (#40477)
add f7b52028e13 [Python] Fix ParquetIO silently corrupting data across
windows in unbounded pipelines (#40293)
No new revisions were added by this update.
Summary of changes:
...beam_PostCommit_Java_ValidatesRunner_Spark.json | 2 +-
...a_ValidatesRunner_SparkStructuredStreaming.json | 3 +-
.../streaming/state/BeamStatefulProcessor.java | 35 ++++--
.../streaming/StatefulParDoStreamingTest.java | 62 ++++++++++
.../spark/stateful/SparkTimerInternals.java | 6 +-
.../spark/stateful/SparkTimerInternalsTest.java | 10 ++
.../org/apache/beam/sdk/io/TextIOReadTest.java | 7 +-
.../org/apache/beam/io/debezium/DebeziumIO.java | 4 +-
sdks/python/apache_beam/io/parquetio.py | 125 ++++++++++++---------
sdks/python/apache_beam/io/parquetio_test.py | 108 ++++++++++++++++++
10 files changed, 291 insertions(+), 71 deletions(-)
