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 bef9ef19056 [Python] Reuse Milvus client in RAG vector sink write path
(#39378)
add f3ef8491a84 Bump actions/setup-python from 4 to 7 (#39386)
add d150fd00d88 Bump github.com/fsouza/fake-gcs-server from 1.52.3 to
1.55.1 in /sdks (#39385)
add 45d1daccfe9 Set persist-credentials true
add 4b3fff3f4a2 Merge pull request #39388 from apache/fix-credentials
add 78261e7af2d Add --add-opens test JVM args for HCatalog and Dataflow
worker tests (#39351)
add 39c60f087fe Support ACKNOWLEDGE_MODE for JmsIO (#39253)
add 023ca6d9a63 [Java] Cache DoFn invoker constructors per instance
(#39310)
add 804b12725f0 add language filtering for codeql (#39327)
add ec397ce5003 [KafkaIO] Remove build support for Kafka clients before
3.9.2 (#39284)
add 0df7069adac Bump protobufjs from 8.6.0 to 8.6.6 in /sdks/typescript
(#39394)
add f4b13a08539 Bump pillow (#39396)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Java_Hadoop_Versions.json | 4 +-
.../beam_Infrastructure_AuditUnmanagedKeys.yml | 4 +-
.../beam_Infrastructure_PolicyEnforcer.yml | 2 +-
.../beam_Infrastructure_SecurityLogging.yml | 2 +-
.../beam_Infrastructure_ServiceAccountKeys.yml | 2 +-
.github/workflows/beam_Publish_Website.yml | 2 +-
.github/workflows/build_release_candidate.yml | 6 +-
.github/workflows/build_wheels.yml | 10 +-
.github/workflows/codeql.yml | 91 +++++++--
.github/workflows/dask_runner_tests.yml | 4 +-
.github/workflows/flaky_test_detection.yml | 2 +-
.github/workflows/pr-bot-new-prs.yml | 2 +-
.github/workflows/pr-bot-pr-updates.yml | 2 +-
.github/workflows/pr-bot-prs-needing-attention.yml | 2 +-
.github/workflows/python_dependency_tests.yml | 2 +-
.github/workflows/refresh_looker_metrics.yml | 2 +-
.../republish_released_docker_containers.yml | 2 +-
.github/workflows/run_perf_alert_tool.yml | 2 +-
.../run_rc_validation_python_mobile_gaming.yml | 2 +-
.../workflows/run_rc_validation_python_yaml.yml | 2 +-
.github/workflows/typescript_tests.yml | 4 +-
CHANGES.md | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 6 +-
examples/java/build.gradle | 4 +-
examples/java/common.gradle | 1 +
.../beam/it/kafka/KafkaResourceManagerTest.java | 3 +-
.../direct/UnboundedReadEvaluatorFactory.java | 13 +-
runners/flink/1.19/build.gradle | 6 +
runners/flink/1.19/job-server/build.gradle | 6 +
runners/flink/1.20/build.gradle | 6 +
runners/flink/1.20/job-server/build.gradle | 6 +
runners/flink/2.0/build.gradle | 6 +
runners/flink/2.0/job-server/build.gradle | 6 +
runners/flink/2.1/build.gradle | 7 -
runners/flink/2.1/job-server/build.gradle | 7 -
runners/flink/2.2/build.gradle | 7 -
runners/flink/2.2/job-server/build.gradle | 7 -
.../google-cloud-dataflow-java/worker/build.gradle | 16 ++
.../worker/DataflowOperationContextTest.java | 6 +-
.../dataflow/worker/status/ThreadzServletTest.java | 15 +-
runners/spark/3/build.gradle | 6 +
runners/spark/3/job-server/build.gradle | 8 +-
runners/spark/4/build.gradle | 5 +
runners/spark/4/job-server/build.gradle | 6 +
runners/spark/spark_runner.gradle | 5 +-
.../streaming/utils/EmbeddedKafkaCluster.java | 17 +-
sdks/go.mod | 6 +-
sdks/go.sum | 35 ++--
.../reflect/ByteBuddyDoFnInvokerFactory.java | 83 +++++---
.../sdk/transforms/reflect/DoFnInvokersTest.java | 47 +++++
sdks/java/io/hcatalog/build.gradle | 4 +
.../apache/beam/sdk/io/jms/JmsCheckpointMark.java | 113 ++++++++---
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 194 ++++++++++++++++---
.../java/org/apache/beam/sdk/io/jms/CommonJms.java | 27 ++-
.../java/org/apache/beam/sdk/io/jms/JmsIOIT.java | 209 ++++++++++++++-------
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 184 +++++++++++++++---
sdks/java/io/kafka/build.gradle | 12 +-
sdks/java/io/kafka/kafka-201/build.gradle | 24 ---
sdks/java/io/kafka/kafka-241/build.gradle | 24 ---
sdks/java/io/kafka/kafka-251/build.gradle | 24 ---
sdks/java/io/kafka/kafka-282/build.gradle | 24 ---
sdks/java/io/kafka/kafka-312/build.gradle | 24 ---
sdks/java/io/kafka/kafka-390/build.gradle | 24 ---
.../io/kafka/{kafka-231 => kafka-392}/build.gradle | 6 +-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 28 +--
.../beam/sdk/io/kafka/KafkaCommitOffsetTest.java | 4 +-
sdks/java/testing/kafka-service/build.gradle | 3 +-
.../apache/beam/sdk/testing/kafka/LocalKafka.java | 11 +-
sdks/java/testing/load-tests/build.gradle | 16 ++
sdks/java/testing/nexmark/build.gradle | 7 +-
sdks/java/testing/tpcds/build.gradle | 7 +-
sdks/java/testing/watermarks/build.gradle | 25 ++-
.../kfp/components/preprocessing/requirements.txt | 2 +-
sdks/typescript/package-lock.json | 18 +-
sdks/typescript/package.json | 2 +-
settings.gradle.kts | 16 +-
76 files changed, 1029 insertions(+), 502 deletions(-)
delete mode 100644 sdks/java/io/kafka/kafka-201/build.gradle
delete mode 100644 sdks/java/io/kafka/kafka-241/build.gradle
delete mode 100644 sdks/java/io/kafka/kafka-251/build.gradle
delete mode 100644 sdks/java/io/kafka/kafka-282/build.gradle
delete mode 100644 sdks/java/io/kafka/kafka-312/build.gradle
delete mode 100644 sdks/java/io/kafka/kafka-390/build.gradle
rename sdks/java/io/kafka/{kafka-231 => kafka-392}/build.gradle (90%)
