This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 468aa4e49eb Add docs about withQueryFn, logic to detect other
functions, and new … (#34127)
add 7f749a9939d Fix hadoop version tests. (#34155)
add a140b5ed789 updated Go to 1.24.0 (#34163)
add bd2541662ee [Java] Allow users to specify GCS custom audit entries in
pipeline options (#34134)
add 103eb8182e3 Add sleep to give enough time for server to be up (#34133)
add 7bff2833a63 enable kafka metrics by default for streaming dataflow
jobs (#34153)
add ed8b1f77811 [Java] Fix UnboundedReaderAsSdfFn to avoid using unstarted
unbounded reader. (#34146)
add 0faa7b8e3be Run Python Postcommit on High mem 22. Increase max nodes
and replicas to 8. (#34170)
add 14b1fa5098f fix for adding unexpected Empty Records in Nested Arrays
in BigQueryIO (#34102)
add c15bd4c380e Add Sequences support to Breaking Changes (#34169)
add c6dee85231c Updates Managed Javadocs and pydocs to refer to runner
specific features
add b76e45acf4c Merge pull request #34072: Updates Managed Javadocs and
pydocs to refer to runner specific features
No new revisions were added by this update.
Summary of changes:
.../actions/setup-environment-action/action.yml | 2 +-
.../arc/environments/beam.env | 4 +-
.../arc/images/Dockerfile | 4 +-
.../beam_PostCommit_Java_Hadoop_Versions.json | 2 +-
...beam_PostCommit_Java_ValidatesRunner_Spark.json | 3 +-
...a_ValidatesRunner_SparkStructuredStreaming.json | 3 +-
...stCommit_Java_ValidatesRunner_Spark_Java11.json | 3 +-
.github/workflows/beam_PostCommit_Python.yml | 2 +-
.github/workflows/build_release_candidate.yml | 2 +-
CHANGES.md | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
dev-support/docker/Dockerfile | 2 +-
.../cloudbuild/playground_ci_examples.sh | 8 +--
runners/spark/spark_runner.gradle | 18 ++++-
sdks/go/run_with_go_version.sh | 2 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 73 +++++++++++++------
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 6 ++
.../sdk/extensions/gcp/options/GcsOptions.java | 64 +++++++++++++++++
.../beam/sdk/extensions/gcp/util/Transport.java | 14 +++-
.../sdk/extensions/gcp/options/GcsOptionsTest.java | 78 ++++++++++++++++++++
.../sdk/extensions/gcp/util/TransportTest.java | 21 +++++-
.../bigquery/StorageApiWriteUnshardedRecords.java | 4 +-
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 15 ++--
.../bigquery/TableRowToStorageApiProtoTest.java | 82 ++++++++++++++++++++++
.../beam/sdk/io/kafka/KafkaIOInitializer.java | 5 +-
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 2 +
.../java/org/apache/beam/sdk/managed/Managed.java | 7 ++
sdks/python/apache_beam/transforms/managed.py | 7 ++
28 files changed, 385 insertions(+), 53 deletions(-)
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/options/GcsOptionsTest.java
