This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/pip/sdks/python/container/ml/py313/torch-2.12.0
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 41bf73d4216 Bump torch from 2.8.0+cpu to 2.12.1 in
/sdks/python/container/ml/py313
add a467fdc437f Enable precommit yaml xlang test on code push. (#39071)
add f61d0b5eeff Release Note: Rename Dataflow Runner to Dataflow Portable
Runner (#38747)
add f29d9af139a init (#39025)
add 447899e46e9 [mqtt] Add Python Xlang Messaging PostCommit with MQTT
integration tests (#38966)
add cedfd0bb3e8 [ReduceFnRunner] Fix Prefetches (#39082)
add c3d9a731b42 [Dataflow Streaming] Increase stuck commit invalidation
timeout to 1 hour (#39083)
add 24e9ed4e0e9 Bump actions/cache from 4 to 6 (#39081)
add f7f0e1655d5 Bump actions/checkout from 6 to 7 (#39080)
add 0165344ab13 Add UnboundedCountingSource::to for bounded reads from an
UnboundedCountingSource (#39084)
add f33feafb2b2 [Dataflow Java Streaming] Add a timeout to how long
commits will retry to the service. (#39085)
add 857dfc9a875 [mqtt] Fix streaming xlang IT failing the Messaging
PostCommit (#39088)
add 0802263e48e Add a github workflow to publish vllm image. (#39089)
add 8e4ea736213 [Python] Optimize BigQuery copy jobs in file loads using
multi-source copy (#38983)
add 5afb93c8c09 [OpenTelemetry] Turn off gcp otel auth extension by
default. (#38940)
add 4e9e483a51a Fix Flink XVR for Flink 2
add 49fd8745223 Fix Go Flink VR conf path
add 16acfa8a2c6 Update CHANGES.md and website
add f13ccf7afbe Merge pull request #39077 from Abacn/fix-flink-xvr
add 9e28c9d2150 Disable flaky SDF finalization tests
add 6095fd0de62 Merge pull request #39092 from
arunpandianp/disablesdffinalization
add 70b72adffee Fix Install xmllint
add 0aa808dba09 Merge pull request #39094 from apache/cut-release-branch
add cad9f1ebe76 Moving to 2.76.0-SNAPSHOT on master branch.
add beeb715739f Update beam-master (#39095)
add c531095fc40 [GSOC 2026] Adding logic to validate and generate an error
if there are key… (#38992)
add 8d252c4659b update changes log for yaml improvements etc (#39093)
add 3fba9950feb Update beam-master container
add e56ed7718a5 Trigger failed postcommit tests.
add 7454aa6a0bf Merge pull request #39100 from
shunping/update-python-beam-master
add d71c4aca4f4 Fix race condition in DirectRunner executor shutdown
add 0af28db1142 Apply suggested fix
add 23521069470 Merge pull request #39096 from shunping/fix-flaky-rrio-test
add 96733599e6c Fix JsonToRow swallowing downstream errors when runners
fuse transforms. (#39098)
add 8092349ca28 Enable playground tests triggered on cron schedule (#39069)
add 8ecdab8da94 [Iceberg CDC] Import BaseIncrementalChangelogScan (#38823)
add 8c311e45672 [Iceberg CDC] Add utils base, delete reader, and
serializable files (#38821)
add c1898ff68b8 Fix pip ResolutionTooDeep (#39017)
add 9d3694165e1 [Python] Add UnboundedSource SDF wrapper (#19137) (#38724)
add 5eefc931b5d remove infra change (#39104)
add eef26ca8b71 Revert "[Python] Optimize BigQuery copy jobs in file loads
using multi-source copy" (#39106)
add 0c51b0d288b Write append tables can be asynchronous (#39120)
add b642c5cbd0e Fix typo (#39123)
add 56b5a52294d Bump google-cloud-aiplatform (#39113)
add d77d12a47b2 Update cython requirement from <4,>=3.2.5 to >=3.2.6,<4 in
/sdks/python (#39099)
add 5cb2f09298c [Website] Update Python version compatibility table
(#38969)
add 698420027d5 Docs: update Python version support in Python quickstart
(#39122)
add 8ccd1d70c04 including GitHub Actions to schedule daily audits and Add
documentati… (#39116)
add 5a2e98bb712 Fix a flaky test in ApproximateQuantilesTest (#39132)
add e3b4d8c5d0e Fix flaky ML RunInference tests by disabling reshuffle on
beam.Create (#39118)
add 3cca8fa3dac [Dataflow Streaming] Access state/timerinternals via
StepContext (#38991)
add 2e8f75aaf4b Bump actions/checkout from 6 to 7 (#39147)
add b63ea65d6a3 Bump github.com/aws/smithy-go from 1.27.2 to 1.27.3 in
/sdks (#39145)
add 31cd92f5f55 Bump cloud.google.com/go/storage from 1.62.3 to 1.63.0 in
/sdks (#39144)
add edd3bfca48e Fix flaky GcsIOIntegrationTest and handle GCS bucket
creation race conditions (#39130)
add af005ef679c fix post commit yaml test (#39142)
add 31175f9ab82 fix race condition in statesampler with lock for reset
(#39129)
add ccac91ad9b8 add zizmor to existing precommit GHA workflow (#39108)
add f17b370e74a Fix flaky PubSub integration test by deduplicating
messages (#39134)
add 402b41c726d Fix ThreadSanitizer data race and failed RPC calls (#39076)
add 961ed7c31ad [IcebergIO] Fix stale openWriters count in
RecordWriterManager (#39157)
add f909e8a7af9 Use Flink 2.2 container for load tests
add 984df275bf4 debug only change -- preserve cluster to check error
add 397d9c61a27 Set configs for Flink 2
add a0fd9502818 Refactor Flink Load Tests to use native Dataproc
components and Auto Zone
add 3e76ff518fa Remove unnecessary gcloud volume mount from Job Server
add 5d28c414f62 Change memory allocation, use resize feature
add 30a5a00d584 Merge pull request #39154 from apache/flink-load-test-ver
add f9171da59bc Bump github.com/nats-io/nats-server/v2 from 2.14.2 to
2.14.3 in /sdks (#39168)
add aa6942a9853 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#39169)
add fcd105de015 Bump js-yaml from 3.14.2 to 3.15.0 in /website/www (#39172)
add 24a2ccc830a Bump com.gradle.common-custom-user-data-gradle-plugin
(#39166)
add 1c4b2047016 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#39170)
add aec5b5da813 Add embedded NVIDIA Dynamo support to vLLM ModelHandler
(#38701)
add 8f60e69177b Fixed DirectRunner PubSub subscriber client lifecycle
(#39079)
add ed0a5832eb1 Add open telemetry dependency to dataflow worker (#38941)
add a86e6115270 Retry starting SubprocessServer on failure (#39159)
add e34cc96df4d [yaml] - mongodb read normalization (#38772)
add 78fdc959cda [Dataflow Streaming] [Multi Key] Prepare
StreamingModeExecutionContext and StreamingWorkScheduler for multi-key
execution. (#38814)
add aec0392a343 Revert previous workarounds and upgrade TFX stack to
1.21.0 (#39164)
add 74059db52cd Bump google.golang.org/grpc from 1.81.1 to 1.82.0 in /sdks
(#39186)
add f08c259a02e Bump google.golang.org/api from 0.286.0 to 0.287.0 in
/sdks (#39185)
add e87f50e3a9a Fix Python VarIntCoder OverflowError on uint64 values
(#39047)
add d0d754c635d Acknowledge messages asap in pubsub test (#39183)
add 8c0f0e02a82 Update Python Dependencies (#39139)
add 2f7d95d1cf9 [Gemini] Add batching support to Java Remote Inference
(#39067)
add 5f3fc19127e [Gemini] Add retry filter support to the Java Remote
RetryHandler (#39004)
add dac2848f4ae Upgrade TFX stack to 1.21.x and remove numpy/pandas bounds
add c2a62c12f94 Append timestamp to artifact_location and output_vocab
add 11cb59ed70c Upgrade tfx stack. Remove some upper bounds.
add 781ec5cdecf Consolidate the test requirements file to examples.
add 1567148726c Run one-hot test only
add b597f364dbd Remove ml_extra in one-hot load test
add 54783520416 Revert "Run one-hot test only"
add 1876512bb88 Minor edit on requirements.txt
add bc9937ade50 Fix typo
add 4a976d393c9 Merge pull request #39163 from apache/resolution-too-deep
add 00823b29fa4 Migrate MqttIO to HiveMQ Mqtt client (#39180)
add 8610459f7b8 [Gemini] Port client-side throttling to the Java SDK
(#39021)
add ca66eda1bc1 delta lake python/yaml (#39052)
add eed2511dcce Add "-Pjava21Home" to stage docker step (#39181)
add 7b3e2df2ed6 Bump transformers (#39195)
add 61b1fa59cd9 Bump torch from 2.8.0+cpu to 2.12.1 in
/sdks/python/container/ml/py313
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (41bf73d4216)
\
N -- N -- N
refs/heads/dependabot/pip/sdks/python/container/ml/py313/torch-2.12.0
(61b1fa59cd9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.../IO_Iceberg_Integration_Tests.json | 2 +-
.../trigger_files/beam_PostCommit_Go_VR_Flink.json | 2 +-
...it_Java_ValidatesRunner_Dataflow_Streaming.json | 2 +-
..._ValidatesRunner_Dataflow_Streaming_Engine.json | 2 +-
.github/trigger_files/beam_PostCommit_Python.json | 6 +-
.../beam_PostCommit_Python_Examples_Dataflow.json | 4 +-
..._PostCommit_Python_Xlang_Messaging_Direct.json} | 2 +-
.../trigger_files/beam_PostCommit_XVR_Flink.json | 2 +-
.../trigger_files/beam_PostCommit_XVR_Samza.json | 1 -
.../beam_PostCommit_Yaml_Xlang_Direct.json | 2 +-
.github/workflows/README.md | 3 +
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 7 +-
.../beam_Infrastructure_AuditUnmanagedKeys.yml | 69 +
.../beam_LoadTests_Go_CoGBK_Flink_batch.yml | 8 +-
.../beam_LoadTests_Go_Combine_Flink_Batch.yml | 14 +-
.../beam_LoadTests_Go_GBK_Flink_Batch.yml | 14 +-
.../beam_LoadTests_Go_ParDo_Flink_Batch.yml | 6 +-
.../beam_LoadTests_Go_SideInput_Flink_Batch.yml | 8 +-
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 6 +-
.../beam_LoadTests_Python_Combine_Flink_Batch.yml | 16 +-
...am_LoadTests_Python_Combine_Flink_Streaming.yml | 6 +-
.../beam_LoadTests_Python_GBK_Flink_Batch.yml | 16 +-
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 8 +-
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 8 +-
.github/workflows/beam_Playground_Precommit.yml | 1 +
...m_PostCommit_Python_Xlang_Messaging_Direct.yml} | 30 +-
.../beam_PostCommit_Yaml_Xlang_Direct.yml | 6 +-
.../workflows/beam_PreCommit_Flink_Container.yml | 6 +-
.github/workflows/beam_PreCommit_GHA.yml | 6 +-
.../beam_PreCommit_Xlang_Generated_Transforms.yml | 6 +-
.../workflows/beam_PreCommit_Yaml_Xlang_Direct.yml | 7 +-
...Jobs.yml => beam_Publish_Python_VLLM_Image.yml} | 71 +-
.github/workflows/build_release_candidate.yml | 4 +-
.github/workflows/cut_release_branch.yml | 5 +-
...Dataflow_MLTransform_One_Hot_Encoding_Batch.txt | 2 +-
.github/workflows/playground_frontend_test.yml | 2 +-
.github/workflows/tour_of_beam_frontend_test.yml | 2 +-
.test-infra/dataproc/flink_cluster.sh | 78 +-
.test-infra/dataproc/init-actions/docker.sh | 103 --
.test-infra/dataproc/init-actions/flink.sh | 217 ---
CHANGES.md | 10 +-
gradle.properties | 4 +-
infra/enforcement/README.md | 12 +-
infra/enforcement/account_keys.py | 103 +-
infra/enforcement/sending.py | 105 +-
.../org/apache/beam/runners/core/DoFnRunners.java | 4 +-
.../runners/core/LateDataDroppingDoFnRunner.java | 17 +-
.../apache/beam/runners/core/ReduceFnRunner.java | 3 +-
.../core/LateDataDroppingDoFnRunnerTest.java | 4 +-
.../apache/beam/runners/core/ReduceFnTester.java | 20 +-
.../direct/ExecutorServiceParallelExecutor.java | 28 +-
runners/flink/job-server/flink_job_server.gradle | 20 +-
.../wrappers/streaming/WindowDoFnOperator.java | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 10 +-
.../options/DataflowStreamingPipelineOptions.java | 19 +-
.../dataflow/worker/GroupAlsoByWindowsParDoFn.java | 2 +-
.../dataflow/worker/StreamingDataflowWorker.java | 8 +
.../worker/StreamingModeExecutionContext.java | 390 +++++-
.../worker/WindmillReaderIteratorBase.java | 29 +-
.../dataflow/worker/WindmillTimerInternals.java | 23 +
.../dataflow/worker/WindowingWindmillReader.java | 119 +-
.../worker/streaming/ComputationWorkExecutor.java | 43 +-
.../runners/dataflow/worker/streaming/Work.java | 29 +-
.../windmill/client/grpc/GrpcCommitWorkStream.java | 94 +-
.../client/grpc/GrpcWindmillStreamFactory.java | 10 +
.../windmill/state/WindmillStateInternals.java | 17 +
.../processing/ComputationWorkExecutorFactory.java | 33 +-
.../work/processing/StreamingWorkScheduler.java | 312 +++--
.../worker/StreamingDataflowWorkerTest.java | 36 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 3 +-
.../worker/StreamingModeExecutionContextTest.java | 158 ++-
.../worker/WindmillReaderIteratorBaseTest.java | 92 ++
.../worker/WindowingWindmillReaderTest.java | 275 ++++
.../dataflow/worker/WorkerCustomSourcesTest.java | 51 +-
.../dataflow/worker/streaming/WorkTest.java | 132 ++
.../client/grpc/GrpcCommitWorkStreamTest.java | 82 ++
scripts/beam-sql.sh | 2 +-
sdks/go.mod | 34 +-
sdks/go.sum | 72 +-
sdks/go/pkg/beam/core/core.go | 2 +-
sdks/go/test/build.gradle | 2 +-
.../org/apache/beam/sdk/io/CountingSource.java | 40 +-
.../apache/beam/sdk/transforms/AsyncWrapper.java | 10 +-
.../org/apache/beam/sdk/transforms/JsonToRow.java | 8 +-
.../org/apache/beam/sdk/io/CountingSourceTest.java | 36 +
.../beam/sdk/transforms/AsyncWrapperTest.java | 66 +-
.../apache/beam/sdk/transforms/JsonToRowTest.java | 26 +
.../java/org/apache/beam/fn/harness/FnHarness.java | 6 +
.../components/throttling/AdaptiveThrottler.java | 105 ++
.../components/throttling/ReactiveThrottler.java | 78 ++
.../throttling/AdaptiveThrottlerTest.java | 107 ++
.../DeltaReadSchemaTransformProviderTest.java | 127 ++
sdks/java/io/expansion-service/build.gradle | 1 +
sdks/java/io/google-cloud-platform/build.gradle | 1 +
.../sdk/io/gcp/datastore/AdaptiveThrottler.java | 111 --
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 1 +
.../io/gcp/datastore/AdaptiveThrottlerTest.java | 114 --
.../beam/sdk/io/iceberg/IcebergScanConfig.java | 78 +-
.../apache/beam/sdk/io/iceberg/PartitionUtils.java | 100 +-
.../apache/beam/sdk/io/iceberg/ReadFromTasks.java | 4 +-
.../org/apache/beam/sdk/io/iceberg/ReadUtils.java | 137 +-
.../beam/sdk/io/iceberg/RecordWriterManager.java | 5 +-
.../apache/beam/sdk/io/iceberg/ScanTaskReader.java | 4 +-
.../beam/sdk/io/iceberg/SerializableDataFile.java | 100 +-
.../sdk/io/iceberg/SerializableDeleteFile.java | 335 +++++
.../beam/sdk/io/iceberg/cdc/CdcOutputUtils.java | 178 +++
.../beam/sdk/io/iceberg/cdc/CdcReadUtils.java | 698 ++++++++++
.../beam/sdk/io/iceberg/cdc/DeleteReader.java | 309 +++++
.../io/iceberg/cdc/IcebergCdcMetadataColumns.java | 93 ++
.../io/iceberg/cdc/SerializableChangelogTask.java | 282 ++++
.../beam/sdk/io/iceberg/cdc}/package-info.java | 4 +-
.../iceberg/BaseIncrementalChangelogScan.java | 1014 ++++++++++++++
.../java/org/apache/iceberg}/package-info.java | 4 +-
.../IcebergCdcReadSchemaTransformProviderTest.java | 12 +-
.../beam/sdk/io/iceberg/IcebergIOReadTest.java | 83 +-
.../IcebergSchemaTransformTranslationTest.java | 33 +-
.../beam/sdk/io/iceberg/PartitionUtilsTest.java | 68 +
.../apache/beam/sdk/io/iceberg/ReadUtilsTest.java | 59 +-
.../sdk/io/iceberg/SerializableDataFileTest.java | 3 +
.../sdk/io/iceberg/SerializableDeleteFileTest.java | 222 ++++
.../beam/sdk/io/iceberg/TestDataWarehouse.java | 2 +-
.../io/iceberg/catalog/IcebergCatalogBaseIT.java | 7 +-
.../beam/sdk/io/iceberg/cdc/CdcReadUtilsTest.java | 381 ++++++
.../beam/sdk/io/iceberg/cdc/DeleteReaderTest.java | 419 ++++++
.../iceberg/cdc/SerializableChangelogTaskTest.java | 256 ++++
sdks/java/io/mongodb/build.gradle | 2 +
.../beam/sdk/io/mongodb/AggregationQuery.java | 9 +-
...> MongoDbReadSchemaTransformConfiguration.java} | 34 +-
.../MongoDbReadSchemaTransformProvider.java | 151 +++
.../apache/beam/sdk/io/mongodb/MongoDbUtils.java | 131 ++
.../MongoDbReadSchemaTransformProviderTest.java | 221 ++++
.../beam/sdk/io/mongodb/MongoDbUtilsTest.java | 123 ++
sdks/java/io/mqtt/build.gradle | 3 +-
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 182 +--
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 204 +--
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 47 +
.../sdk/ml/inference/remote/RemoteInference.java | 33 +-
.../beam/sdk/ml/inference/remote/RetryHandler.java | 27 +-
.../ml/inference/remote/RemoteInferenceTest.java | 40 +-
.../sdk/ml/inference/remote/RetryHandlerTest.java | 145 ++
sdks/python/apache_beam/coders/coder_impl.pxd | 1 -
sdks/python/apache_beam/coders/coder_impl.py | 34 +-
.../apache_beam/coders/coders_test_common.py | 18 +
.../online_clustering/clustering_pipeline/setup.py | 2 +-
.../examples/inference/vllm_text_completion.py | 24 +-
.../mltransform_generate_vocab_requirements.txt | 10 +-
.../mltransform_one_hot_encoding_requirements.txt} | 16 +-
.../mltransform_one_hot_encoding_test.py | 2 -
.../io/external/xlang_mqttio_it_test.py | 268 ++++
.../apache_beam/io/gcp/bigquery_file_loads.py | 2 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 13 +-
.../apache_beam/io/gcp/gcsio_integration_test.py | 21 +-
sdks/python/apache_beam/io/gcp/gcsio_test.py | 40 +
.../apache_beam/io/gcp/pubsub_integration_test.py | 26 +-
sdks/python/apache_beam/io/gcp/pubsub_test.py | 79 +-
sdks/python/apache_beam/io/iobase.py | 14 +-
sdks/python/apache_beam/io/iobase_test.py | 49 +-
sdks/python/apache_beam/io/unbounded_source.py | 996 ++++++++++++++
.../python/apache_beam/io/unbounded_source_test.py | 1380 ++++++++++++++++++++
sdks/python/apache_beam/ml/inference/base_test.py | 2 +-
.../ml/inference/pytorch_inference_test.py | 5 +-
.../ml/inference/sklearn_inference_test.py | 4 +-
.../ml/inference/tensorflow_inference_test.py | 4 +-
.../ml/inference/tensorrt_inference_test.py | 11 +-
.../inference/test_resources/vllm.dockerfile.old | 14 +-
.../apache_beam/ml/inference/vllm_inference.py | 331 ++++-
.../ml/inference/vllm_inference_test.py | 157 +++
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../runners/direct/transform_evaluator.py | 113 +-
.../runners/worker/statesampler_fast.pyx | 11 +-
.../testing/benchmarks/cloudml/requirements.txt | 16 +-
sdks/python/apache_beam/transforms/async_dofn.py | 4 +-
.../apache_beam/transforms/async_dofn_test.py | 47 +
sdks/python/apache_beam/transforms/external.py | 1 +
sdks/python/apache_beam/transforms/managed.py | 4 +-
sdks/python/apache_beam/transforms/stats_test.py | 20 +-
sdks/python/apache_beam/transforms/util_test.py | 49 +
sdks/python/apache_beam/utils/subprocess_server.py | 89 +-
.../apache_beam/utils/subprocess_server_test.py | 22 +-
sdks/python/apache_beam/version.py | 2 +-
.../yaml/extended_tests/databases/iceberg.yaml | 54 +-
sdks/python/apache_beam/yaml/integration_tests.py | 96 ++
sdks/python/apache_beam/yaml/standard_io.yaml | 15 +-
.../python/apache_beam/yaml/tests/delta.yaml | 24 +-
sdks/python/apache_beam/yaml/tests/mongodb.yaml | 40 +-
sdks/python/apache_beam/yaml/yaml_io.py | 82 +-
.../container/ml/py310/base_image_requirements.txt | 34 +-
.../container/ml/py310/gpu_image_requirements.txt | 44 +-
.../container/ml/py311/base_image_requirements.txt | 34 +-
.../container/ml/py311/gpu_image_requirements.txt | 44 +-
.../container/ml/py312/base_image_requirements.txt | 34 +-
.../container/ml/py312/gpu_image_requirements.txt | 44 +-
.../container/ml/py313/base_image_requirements.txt | 34 +-
.../container/py310/base_image_requirements.txt | 32 +-
.../container/py311/base_image_requirements.txt | 32 +-
.../container/py312/base_image_requirements.txt | 32 +-
.../container/py313/base_image_requirements.txt | 32 +-
.../container/py314/base_image_requirements.txt | 30 +-
sdks/python/pyproject.toml | 2 +-
sdks/python/pytest.ini | 1 +
sdks/python/test-suites/dataflow/common.gradle | 48 +-
sdks/python/test-suites/direct/build.gradle | 6 +
sdks/python/test-suites/xlang/build.gradle | 8 +-
sdks/standard_expansion_services.yaml | 1 +
sdks/standard_external_transforms.yaml | 34 +
sdks/typescript/package.json | 2 +-
settings.gradle.kts | 2 +-
.../site/content/en/documentation/runners/flink.md | 4 +-
.../site/content/en/documentation/sdks/python.md | 6 +-
.../site/content/en/get-started/quickstart-py.md | 2 +-
website/www/yarn.lock | 6 +-
212 files changed, 12875 insertions(+), 2138 deletions(-)
copy .github/trigger_files/{beam_PostCommit_Java_Hadoop_Versions.json =>
beam_PostCommit_Python_Xlang_Messaging_Direct.json} (98%)
delete mode 100644 .github/trigger_files/beam_PostCommit_XVR_Samza.json
create mode 100644 .github/workflows/beam_Infrastructure_AuditUnmanagedKeys.yml
copy .github/workflows/{beam_PostCommit_Python_MongoDBIO_IT.yml =>
beam_PostCommit_Python_Xlang_Messaging_Direct.yml} (82%)
copy .github/workflows/{beam_CancelStaleDataflowJobs.yml =>
beam_Publish_Python_VLLM_Image.yml} (55%)
delete mode 100644 .test-infra/dataproc/init-actions/docker.sh
delete mode 100644 .test-infra/dataproc/init-actions/flink.sh
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/WindowingWindmillReaderTest.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/streaming/WorkTest.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/throttling/AdaptiveThrottler.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/throttling/ReactiveThrottler.java
create mode 100644
sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/throttling/AdaptiveThrottlerTest.java
create mode 100644
sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaReadSchemaTransformProviderTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/AdaptiveThrottler.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/AdaptiveThrottlerTest.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/SerializableDeleteFile.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/CdcOutputUtils.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/CdcReadUtils.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/DeleteReader.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/IcebergCdcMetadataColumns.java
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc/SerializableChangelogTask.java
copy sdks/java/{core/jmh/src/main/java/org/apache/beam/sdk/jmh/io =>
io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/cdc}/package-info.java
(91%)
create mode 100644
sdks/java/io/iceberg/src/main/java/org/apache/iceberg/BaseIncrementalChangelogScan.java
copy
{runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state
=> sdks/java/io/iceberg/src/main/java/org/apache/iceberg}/package-info.java
(90%)
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/SerializableDeleteFileTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/CdcReadUtilsTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/DeleteReaderTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/SerializableChangelogTaskTest.java
copy
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/{MongoDbWriteSchemaTransformConfiguration.java
=> MongoDbReadSchemaTransformConfiguration.java} (69%)
create mode 100644
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbReadSchemaTransformProvider.java
create mode 100644
sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbReadSchemaTransformProviderTest.java
create mode 100644
sdks/java/ml/inference/remote/src/test/java/org/apache/beam/sdk/ml/inference/remote/RetryHandlerTest.java
rename
sdks/python/apache_beam/{ml/transforms/mltransform_tests_requirements.txt =>
examples/ml_transform/mltransform_one_hot_encoding_requirements.txt} (82%)
create mode 100644 sdks/python/apache_beam/io/external/xlang_mqttio_it_test.py
create mode 100644 sdks/python/apache_beam/io/unbounded_source.py
create mode 100644 sdks/python/apache_beam/io/unbounded_source_test.py
create mode 100644 sdks/python/apache_beam/ml/inference/vllm_inference_test.py
copy
.test-infra/kafka/strimzi/02-kafka-persistent/overlays/gke-internal-load-balanced/kustomization.yaml
=> sdks/python/apache_beam/yaml/tests/delta.yaml (66%)
