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 0bc785253eb Fix WriteToPubSub to pass ordering_key to publish() method
(#37345)
add d032f0e3ef4 Add drain support for Dataflow and Flink (#38786)
add c608b4da8de Bump google.golang.org/api from 0.284.0 to 0.285.0 in
/sdks (#38997)
add 9765e29de68 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#38998)
add 6ccd0c9c861 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#38999)
add b9342767cc5 fix sentence (#38989)
add 597f92530f1 address DOM text reinterpreted as HTML alert (#38949)
add 56d4ffdab31 Align gcpauth extension implementation with ability to
turn it off easily while still being added as dependency.
add 2802de39b2e Merge pull request #38846: [OpenTelemetry] Add turning off
to gcpauth extension
add ee92a553e5d Disable public IP for Dataflow Python and Go Validate
runner tests (#38990)
add 1c182507444 Add support for Apache Flink 2.1.3 (#38961)
add 1d703fe904f Make ModelManager import more robust (#38936)
add 849fcf89c81 [Beam SQL Shell] Add Iceberg deps when using icebergio
(#38994)
add a3f9e0e7d96 Add publish_time_field to ReadFromPubSub YAML transform
(#38985)
No new revisions were added by this update.
Summary of changes:
.../test-properties.json | 2 +-
.github/trigger_files/beam_PostCommit_Go.json | 2 +-
...PostCommit_Python_ValidatesRunner_Dataflow.json | 2 +-
.../run_rc_validation_java_quickstart.yml | 2 +-
.test-infra/validate-runner/build.gradle | 13 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 1 +
examples/java/common.gradle | 10 +
gradle.properties | 2 +-
runners/flink/{2.0 => 2.1}/build.gradle | 17 +-
.../job-server-container/build.gradle | 0
.../flink/{1.19 => 2.1}/job-server/build.gradle | 15 +-
.../runners/flink/FlinkDetachedRunnerResult.java | 60 ++++-
.../beam/runners/flink/FlinkRunnerResult.java | 6 +
.../beam/runners/flink/FlinkRunnerResultTest.java | 92 +++++++
.../beam/runners/dataflow/DataflowPipelineJob.java | 67 +++--
.../runners/dataflow/DataflowPipelineJobTest.java | 46 ++++
scripts/beam-sql.sh | 73 +++++-
sdks/go.mod | 8 +-
sdks/go.sum | 16 +-
sdks/go/examples/wasm/README.md | 6 +-
sdks/go/test/build.gradle | 5 +-
.../java/org/apache/beam/sdk/PipelineResult.java | 13 +
.../opentelemetry-gcp-auth-extension/build.gradle | 1 +
.../opentelemetry/gcp/auth/ConfigurableOption.java | 1 +
...GcpAuthAutoConfigurationCustomizerProvider.java | 196 ++++++++-------
...uthAutoConfigurationCustomizerProviderTest.java | 276 +++++++++++++--------
sdks/python/apache_beam/ml/inference/base.py | 6 +
.../python/apache_beam/options/pipeline_options.py | 2 +-
sdks/python/apache_beam/yaml/yaml_io.py | 21 +-
sdks/python/apache_beam/yaml/yaml_io_test.py | 103 ++++++++
sdks/python/scripts/run_integration_test.sh | 11 +-
sdks/python/test-suites/dataflow/common.gradle | 2 +
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
website/www/site/assets/js/bootstrap.js | 46 +++-
website/www/site/assets/js/bootstrap/alert.js | 7 +-
website/www/site/assets/js/bootstrap/carousel.js | 9 +-
website/www/site/assets/js/bootstrap/collapse.js | 6 +-
website/www/site/assets/js/bootstrap/dropdown.js | 7 +-
website/www/site/assets/js/bootstrap/modal.js | 8 +-
website/www/site/assets/js/bootstrap/tooltip.js | 9 +-
.../site/content/en/documentation/dsls/sql/ddl.md | 2 +-
41 files changed, 902 insertions(+), 271 deletions(-)
copy runners/flink/{2.0 => 2.1}/build.gradle (79%)
copy runners/flink/{1.17 => 2.1}/job-server-container/build.gradle (100%)
copy runners/flink/{1.19 => 2.1}/job-server/build.gradle (71%)
