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 a3f9e0e7d96 Add publish_time_field to ReadFromPubSub YAML transform
(#38985)
add 15d00559d75 Bump cloud.google.com/go/bigtable from 1.49.0 to 1.50.0 in
/sdks (#39012)
add 5c34e1c1c85 Exclude tests for batch-dataset (#39014)
add 9e465a7cfd7 fix parsing error for typescript (#38898)
add c81059fb246 Drop Flink 1.17,1.18 support (#39006)
add 466989d50a4 cancel user code with interruption after timeout (#39018)
add 09c962c4aef Fix Milvus ML PreCommit xdist, container startup (#39007)
add b4e023afece Bump nodemailer from 8.0.5 to 9.0.1 in
/scripts/ci/issue-report (#39019)
add 17bed431e05 remove shardedKey (#39024)
add 63bcd3dd2b5 Validate Project of staging bucket (#39008)
No new revisions were added by this update.
Summary of changes:
.../test-properties.json | 2 +-
.../IO_Iceberg_Integration_Tests.json | 2 +-
.../trigger_files/beam_PreCommit_Python_ML.json | 2 +-
.../workflows/beam_PreCommit_Flink_Container.yml | 2 +-
gradle.properties | 2 +-
runners/flink/1.17/build.gradle | 25 ------
.../flink/1.17/job-server-container/build.gradle | 26 ------
runners/flink/1.17/job-server/build.gradle | 31 --------
runners/flink/1.18/build.gradle | 25 ------
.../flink/1.18/job-server-container/build.gradle | 26 ------
runners/flink/1.18/job-server/build.gradle | 31 --------
.../flink/streaming/MemoryStateBackendWrapper.java | 80 -------------------
.../runners/flink/streaming/StreamSources.java | 61 --------------
runners/flink/job-server/flink_job_server.gradle | 2 +-
.../flink/streaming/MemoryStateBackendWrapper.java | 28 ++++---
.../runners/flink/streaming/StreamSources.java | 7 ++
scripts/ci/issue-report/package-lock.json | 14 ++--
scripts/ci/issue-report/package.json | 2 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/go/examples/wasm/README.md | 2 +-
.../org/apache/beam/sdk/io/iceberg/AddFiles.java | 11 ++-
.../org/apache/beam/io/requestresponse/Call.java | 1 +
sdks/python/apache_beam/io/gcp/gcsio.py | 50 +++++++++++-
sdks/python/apache_beam/io/gcp/gcsio_test.py | 92 ++++++++++++++++++++++
.../ml/rag/enrichment/milvus_search_it_test.py | 1 +
.../ml/rag/ingestion/milvus_search_it_test.py | 1 +
sdks/python/apache_beam/ml/rag/test_utils.py | 1 +
.../python/apache_beam/options/pipeline_options.py | 2 +-
sdks/python/setup.py | 1 +
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
website/www/site/assets/js/page-nav.js | 2 +-
32 files changed, 193 insertions(+), 347 deletions(-)
delete mode 100644 runners/flink/1.17/build.gradle
delete mode 100644 runners/flink/1.17/job-server-container/build.gradle
delete mode 100644 runners/flink/1.17/job-server/build.gradle
delete mode 100644 runners/flink/1.18/build.gradle
delete mode 100644 runners/flink/1.18/job-server-container/build.gradle
delete mode 100644 runners/flink/1.18/job-server/build.gradle
delete mode 100644
runners/flink/1.19/src/test/java/org/apache/beam/runners/flink/streaming/MemoryStateBackendWrapper.java
delete mode 100644
runners/flink/1.19/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
