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 6cd15e7bed1 BigTable write SchemaTransform and Python wrapper (#27146)
add 32b732b9c4c [Security] Upgrade guava to 32.0.1-jre (#27279)
add 566fcc10e08 Bump cloud.google.com/go/pubsub from 1.31.0 to 1.32.0 in
/sdks (#27282)
add f7e8cfb3599 Programmatically choose target Beam version for Automated
Expansion Service tests (#27274)
add a8cf6964e07 Add explicit PortablePipelineOptions.enableHeapDumps to
control heap dumping. (#26982)
add 0554372b25b Finish Java Exception Sampling (#27257)
add f26afc05e23 [Python] Add note for using TF2 models with TensorFlow Hub
(#27276)
add 6ccc1c19412 Bump cloud.google.com/go/datastore from 1.11.0 to 1.12.0
in /sdks (#27281)
add 2ea1045bf57 Add boilerplate Java21 security properties support to sdk
containers (#26798)
add a6b147a8184 Fix cleanUpDockerJavaImages fail (#27287)
add 23fe94b3af2 Implement Exception Sampling in the Python SDK (#27280)
add d44afac8fe5 Moving to 2.50.0-SNAPSHOT on master branch.
add cbeb123949a Bump datastore-v1-proto-client dependency to match
libraries-bom (#27285)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
.../run_inference_with_tensorflow_hub.ipynb | 19 +-
gradle.properties | 4 +-
release/src/main/scripts/jenkins_jobs.txt | 2 -
.../scripts/cleanup_untagged_gcr_images.sh | 3 +-
sdks/go.mod | 4 +-
sdks/go.sum | 10 +-
sdks/go/pkg/beam/core/core.go | 2 +-
sdks/go/test/integration/xlang/expansion_test.go | 41 ++-
.../java21-security.properties} | 19 +-
.../option-java21-security.json} | 2 +-
.../beam/sdk/options/PortablePipelineOptions.java | 17 ++
.../fn/harness/control/ExecutionStateSampler.java | 16 +-
.../harness/data/PCollectionConsumerRegistry.java | 27 +-
.../beam/fn/harness/debug/ElementSample.java | 15 +-
.../beam/fn/harness/debug/OutputSampler.java | 93 ++++--
.../beam/fn/harness/status/MemoryMonitor.java | 4 +-
.../beam/fn/harness/debug/OutputSamplerTest.java | 91 +++++-
.../fn/harness/status/BeamFnStatusClientTest.java | 2 +-
sdks/python/apache_beam/runners/common.pxd | 2 +
sdks/python/apache_beam/runners/common.py | 35 ++-
.../apache_beam/runners/worker/bundle_processor.py | 20 +-
.../runners/worker/bundle_processor_test.py | 142 +++++++--
.../apache_beam/runners/worker/data_sampler.py | 139 +++++++--
.../runners/worker/data_sampler_test.py | 330 +++++++++++++--------
.../apache_beam/runners/worker/operations.pxd | 4 +
.../apache_beam/runners/worker/operations.py | 48 +--
.../apache_beam/runners/worker/sdk_worker.py | 10 +-
.../apache_beam/runners/worker/sdk_worker_test.py | 17 +-
sdks/python/apache_beam/version.py | 2 +-
sdks/typescript/package.json | 2 +-
31 files changed, 831 insertions(+), 299 deletions(-)
copy sdks/java/container/{java17/java17-security.properties =>
java21/java21-security.properties} (75%)
copy sdks/java/container/{java11/option-java11-security.json =>
java21/option-java21-security.json} (86%)
