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 354a3878fca Fix panic in teststream. (#36227)
add 7b22d6199b5 Bump github.com/docker/docker in /sdks (#36230)
add a5c98500f83 [Java] Change precondition checks to use lazy formatting
(#36065)
add 6d80ed6c087 Bump github.com/testcontainers/testcontainers-go in /sdks
(#36231)
add 8fd07a40087 Revert "Cleanly separate v1 worker and v2 sdk harness
container image handling in DataflowRunner" (#36216)
add 11f75687d68 Remove Vertex LLM Inference Integration Test (#36172)
add df255a34fe4 Bump cloud.google.com/go/storage from 1.56.1 to 1.56.2 in
/sdks (#36204)
add d26dbacc8e4 Add support for PROTO format in YAML Pub/Sub transform
(#36185)
add 350537f782a Remove (inactive) key from example (#36234)
add 91460292891 Fix a deadlock situation for BlockOnSplit test case.
(#36226)
add cf55feeb880 Fix Null Pointer Exception in BigQueryIO (#36209)
add c7b6576a7b5 [python] Fix output pcollections of composite transforms
that return DoOutputsTuple (#36220)
add 4c8fdf699f6 Update import gpg action version
add 805796377b0 Adding release-2.68.0-postrelease to protected branches in
.asf.yaml
add 42aed71971a blog: GSoC 2025 - Beam YAML, Kafka and Iceberg User
Accessibility (#36233)
add 08b0572d54c Fix bug when execute DataframeTransform a dictionary of
Pcoll (#35893)
add 85b27030d29 Update Beam website to release 2.68.0
add e4142f41a96 Update dates
add 16b31376fea Update links
add 6ec46786250 Merge pull request #36136 from apache/release-268-website
add 990b5ffb30b [Prism] Support injecting triggered bundle for a batch of
elements. (#36219)
add 43c8285ff09 Add liferoad to go reviewwer. (#36239)
add 757ffcdc3b9 fix(pipeline): Handle missing side_inputs in
AppliedPTransform (#36238)
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/REVIEWERS.yml | 1 +
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
.github/workflows/finalize_release.yml | 16 +--
CHANGES.md | 14 +--
.../datatokenization/utils/SchemasUtils.java | 5 +-
.../anomaly_detection_timesfm.ipynb | 4 +-
.../SplittableProcessElementsEvaluatorFactory.java | 3 +-
.../dataflow/DataflowPipelineTranslator.java | 7 +-
.../beam/runners/dataflow/DataflowRunner.java | 127 ++++++++-------------
.../options/DataflowPipelineWorkerPoolOptions.java | 13 ++-
.../dataflow/util/CloudObjectTranslators.java | 2 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 12 +-
.../beam/runners/dataflow/DataflowRunnerTest.java | 50 +++++---
.../worker/GroupAlsoByWindowParDoFnFactory.java | 9 +-
.../runners/dataflow/worker/InMemoryReader.java | 6 +-
.../fnexecution/environment/ProcessManager.java | 2 +-
.../runners/fnexecution/wire/CommonCoderTest.java | 4 +-
.../runners/spark/util/SparkSideInputReader.java | 2 +-
.../twister2/utils/Twister2SideInputReader.java | 2 +-
sdks/go.mod | 11 +-
sdks/go.sum | 25 ++--
.../go/pkg/beam/core/runtime/exec/dynsplit_test.go | 4 +-
.../prism/internal/engine/elementmanager.go | 95 +++++++++------
sdks/go/pkg/beam/runners/prism/internal/execute.go | 13 +++
.../TFRecordReadSchemaTransformConfiguration.java | 3 +-
.../java/org/apache/beam/sdk/schemas/Schema.java | 3 +-
.../beam/sdk/schemas/SchemaCoderHelpers.java | 2 +-
.../beam/sdk/transforms/DoFnOutputReceivers.java | 2 +-
.../sdk/extensions/protobuf/ProtoByteUtils.java | 2 +-
.../sql/impl/parser/SqlCreateCatalog.java | 2 +-
.../sql/meta/catalog/InMemoryCatalog.java | 2 +-
.../sql/meta/provider/test/TestTableProvider.java | 2 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 6 +-
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 4 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 21 ++--
.../beam/sdk/io/gcp/spanner/MutationUtils.java | 2 +-
.../beam/sdk/io/gcp/spanner/StructUtils.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 30 ++++-
.../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 19 +--
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 2 +-
sdks/python/apache_beam/dataframe/transforms.py | 2 +-
.../apache_beam/dataframe/transforms_test.py | 20 ++++
.../apache_beam/examples/inference/README.md | 6 +
.../inference/vertex_ai_llm_text_classification.py | 10 ++
.../ml/inference/vertex_ai_inference_it_test.py | 17 ---
sdks/python/apache_beam/pipeline.py | 10 +-
sdks/python/apache_beam/pipeline_test.py | 53 +++++++++
.../runners/portability/prism_runner_test.py | 70 +++++++++++-
sdks/python/apache_beam/yaml/yaml_io.py | 13 ++-
sdks/python/apache_beam/yaml/yaml_io_test.py | 45 ++++++++
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.68.0.md | 83 ++++++++++++++
.../en/blog/gsoc-25-yaml-user-accessibility.md | 113 ++++++++++++++++++
.../www/site/content/en/get-started/downloads.md | 18 ++-
55 files changed, 726 insertions(+), 270 deletions(-)
create mode 100644 website/www/site/content/en/blog/beam-2.68.0.md
create mode 100644
website/www/site/content/en/blog/gsoc-25-yaml-user-accessibility.md
