You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2025/09/19 04:01:36 UTC
(beam) branch nightly-refs/heads/master updated (117042c4ca5 -> d6422d1277a)
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 117042c4ca5 Add liferoad to build reviewers list (#36186)
add dfeea359aef [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead (#36165)
add 93a38d6e56e Upgrade iceberg to 1.10.0 (#36123)
add 06ed09aabe1 Bump jlumbroso/free-disk-space from 1.3.0 to 1.3.1 (#36189)
add c0e4e45fca8 Bump python SDK harness to beam-master-20250917 (#36187)
add 3cad999e305 fix(pubsub): handle pubsub message attributes correctly in write (#36140)
add 6251f1017e1 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#36116)
add db18391bb86 Add missing format strings to logging calls (#36192)
add 3ae6b63aa31 Bump transformers in /sdks/python/apache_beam/ml/inference (#36162)
add 996e544ab5c Fix a typo (#36195)
add 3e5d68cb77a Bump torch (#36018)
add 9504399b375 Fix print statement format in symtab package (#36198)
add a0d5c87ec75 Only report timeout duration parsing error during harness start. (#36194)
add c1618ba8c44 [Go SDK] Propagate paneInfo correctly. (#36191)
add 38e10f5757f Bump github.com/nats-io/nats-server/v2 from 2.11.6 to 2.11.9 in /sdks (#36105)
add 75c3274622c Bump cloud.google.com/go/pubsub from 1.50.0 to 1.50.1 in /sdks (#36058)
add 87f48e7783a Capture build scans from TypeScript tests (#36197)
add 3d648211f01 Bump github.com/fsouza/fake-gcs-server from 1.52.2 to 1.52.3 in /sdks (#35970)
add d6422d1277a Bump golang.org/x/sync from 0.16.0 to 0.17.0 in /sdks (#36115)
No new revisions were added by this update.
Summary of changes:
.../IO_Iceberg_Integration_Tests.json | 2 +-
...Iceberg_Managed_Integration_Tests_Dataflow.json | 2 +-
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
.github/trigger_files/beam_PostCommit_SQL.json | 2 +-
...Tests_Dataflow.json => beam_PreCommit_SQL.json} | 0
.github/workflows/build_release_candidate.yml | 4 +-
.../republish_released_docker_containers.yml | 2 +-
.github/workflows/typescript_tests.yml | 35 +-
CHANGES.md | 1 +
.../notebooks/beam-ml/dataflow_tpu_examples.ipynb | 2 +-
.../reading-from-text/description.md | 4 +-
runners/direct-java/build.gradle | 2 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 34 +-
.../worker/windmill/state/WindmillStateUtil.java | 56 +-
.../windmill/state/WindmillStateUtilTest.java | 87 +
runners/jet/build.gradle | 2 +-
.../Twister2PipelineExecutionEnvironment.java | 2 +-
sdks/go.mod | 47 +-
sdks/go.sum | 100 +-
sdks/go/cmd/symtab/main.go | 2 +-
sdks/go/container/tools/buffered_logging.go | 4 +-
sdks/go/container/tools/logging_test.go | 2 +-
sdks/go/pkg/beam/beam.shims.go | 240 ++-
sdks/go/pkg/beam/core/runtime/exec/emit.go | 8 +-
.../beam/core/runtime/exec/optimized/emitters.go | 2028 ++++++++++----------
.../beam/core/runtime/exec/optimized/emitters.tmpl | 12 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 10 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 17 +-
.../pkg/beam/core/runtime/harness/harness_test.go | 40 +-
sdks/go/pkg/beam/register/emitter.go | 12 +-
sdks/go/pkg/beam/register/emitter_test.go | 8 +-
.../pkg/beam/runners/dataflow/dataflowlib/job.go | 2 +-
.../runners/vet/testpipeline/testpipeline.shims.go | 6 +-
sdks/go/pkg/beam/testing/passert/passert.shims.go | 111 +-
sdks/go/pkg/beam/util/shimx/generate.go | 6 +-
sdks/go/pkg/beam/x/debug/debug.shims.go | 109 +-
.../beam/sdk/util/ByteStringOutputStream.java | 10 +
.../beam/sdk/util/ByteStringOutputStreamTest.java | 13 +
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 2 +-
sdks/java/io/iceberg/build.gradle | 4 +-
.../apache/beam/sdk/io/iceberg/RecordWriter.java | 2 +-
.../beam/sdk/io/iceberg/IcebergIOWriteTest.java | 2 +-
.../beam/sdk/io/iceberg/TestDataWarehouse.java | 2 +-
.../io/iceberg/catalog/IcebergCatalogBaseIT.java | 2 +-
.../kfp/components/preprocessing/requirements.txt | 2 +-
sdks/python/apache_beam/io/gcp/pubsub.py | 88 +-
.../apache_beam/io/gcp/pubsub_integration_test.py | 4 +-
.../inference/huggingface_tests_requirements.txt | 2 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
sdks/python/apache_beam/runners/render.py | 2 +-
.../transforms/elementwise/regex_matches.yaml | 2 +-
sdks/python/container/boot.go | 6 +-
.../containers/tensorrt_runinference/README.md | 2 +-
sdks/typescript/.mocharc.json | 6 +
.../typescript/develocity.config.js | 13 +-
sdks/typescript/package-lock.json | 68 +-
sdks/typescript/package.json | 1 +
.../typescript/reporterConfig.js | 12 +-
58 files changed, 1788 insertions(+), 1462 deletions(-)
copy .github/trigger_files/{IO_Iceberg_Integration_Tests_Dataflow.json => beam_PreCommit_SQL.json} (100%)
create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateUtilTest.java
create mode 100644 sdks/typescript/.mocharc.json
copy website/www/site/assets/js/anchor-content-jump-fix.js => sdks/typescript/develocity.config.js (76%)
copy website/www/site/assets/js/anchor-content-jump-fix.js => sdks/typescript/reporterConfig.js (76%)