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 d7557af6a55 [Spark 4] Add streaming dispatch seam and lifecycle hooks
(#39906)
add 470454db370 Bump cloud.google.com/go/spanner from 1.94.0 to 1.95.0 in
/sdks (#39913)
add a057f722cda Try fix miniCluster jar (#39912)
add 13044d31d78 Fix MongoDbIO read splitting to preserve non-ObjectId _id
types (#39901)
add 8288d2f15d0 Update commons-pool2 dependency to 2.13.1 in JDBC IO
(#39914)
add ade938f14f3 Update Beam website roadmap pages (#39899)
add 85f7a48781c datastore: Same key in mutation batch
add 2c2036fe168 Merge branch 'master' into repeated-keys-datastore-writes
add 6dbbdda8c6c datastore: assert return value of adding to set
add 52d74b914e3 Merge pull request #37751: datastore: Same key in mutation
batch
add 25cb8b76a96 fix(beam): guard jinja_variable_flags collision with
pipeline options (#39888)
add bd9620f61c0 [Spark] Fire processing-time timers in timestamp order
(#39825)
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 | 2 +
runners/flink/job-server/flink_job_server.gradle | 8 +-
runners/portability/test_flink_uber_jar.sh | 12 ++-
.../spark/stateful/SparkTimerInternals.java | 52 ++++++----
.../apache/beam/runners/spark/util/TimerUtils.java | 7 +-
.../spark/stateful/SparkTimerInternalsTest.java | 106 +++++++++++++++++++++
.../beam/runners/spark/util/TimerUtilsTest.java | 20 ++++
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 6 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 46 +++++++++
sdks/java/io/jdbc/build.gradle | 2 +-
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 69 +++++++-------
.../apache/beam/sdk/io/mongodb/MongoDbIOTest.java | 52 ++++++++--
sdks/python/apache_beam/yaml/main.py | 10 ++
sdks/python/apache_beam/yaml/main_test.py | 14 +++
website/www/site/content/en/roadmap/_index.md | 40 ++++----
.../site/content/en/roadmap/connectors-go-sdk.md | 27 ------
.../site/content/en/roadmap/connectors-java-sdk.md | 36 -------
.../content/en/roadmap/connectors-multi-sdk.md | 92 ++++--------------
.../content/en/roadmap/connectors-python-sdk.md | 29 ------
.../www/site/content/en/roadmap/dataflow-runner.md | 9 +-
website/www/site/content/en/roadmap/euphoria.md | 2 +
.../www/site/content/en/roadmap/flink-runner.md | 20 +++-
website/www/site/content/en/roadmap/go-sdk.md | 15 ++-
website/www/site/content/en/roadmap/java-sdk.md | 9 +-
.../www/site/content/en/roadmap/prism-runner.md | 2 +
website/www/site/content/en/roadmap/python-sdk.md | 35 +++++--
.../www/site/content/en/roadmap/spark-runner.md | 18 +++-
.../layouts/partials/section-menu/en/roadmap.html | 16 ++--
32 files changed, 473 insertions(+), 293 deletions(-)
create mode 100644
runners/spark/src/test/java/org/apache/beam/runners/spark/stateful/SparkTimerInternalsTest.java
delete mode 100644 website/www/site/content/en/roadmap/connectors-go-sdk.md
delete mode 100644 website/www/site/content/en/roadmap/connectors-java-sdk.md
delete mode 100644 website/www/site/content/en/roadmap/connectors-python-sdk.md
