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 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)
No new revisions were added by this update.
Summary of changes:
..._ValidatesRunner_Dataflow_Streaming_Engine.json | 2 +-
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
.../beam_PostCommit_Yaml_Xlang_Direct.json | 2 +-
.../beam_Infrastructure_AuditUnmanagedKeys.yml | 2 +-
.github/workflows/beam_PreCommit_GHA.yml | 6 +-
.../org/apache/beam/runners/core/DoFnRunners.java | 4 +-
.../runners/core/LateDataDroppingDoFnRunner.java | 17 +++--
.../core/LateDataDroppingDoFnRunnerTest.java | 4 +-
.../apache/beam/runners/core/ReduceFnTester.java | 20 +++++-
.../wrappers/streaming/WindowDoFnOperator.java | 2 +-
.../dataflow/worker/GroupAlsoByWindowsParDoFn.java | 2 +-
.../worker/StreamingModeExecutionContext.java | 20 ++++++
.../dataflow/worker/WindmillTimerInternals.java | 23 +++++++
.../windmill/state/WindmillStateInternals.java | 17 +++++
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 3 +-
.../worker/StreamingModeExecutionContextTest.java | 60 ++++++++++++++++++
sdks/go.mod | 8 +--
sdks/go.sum | 20 +++---
.../apache/beam/sdk/transforms/AsyncWrapper.java | 10 +--
.../beam/sdk/transforms/AsyncWrapperTest.java | 66 ++++++++++++++++++-
.../beam/sdk/io/iceberg/RecordWriterManager.java | 5 +-
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 | 22 +++++--
.../runners/worker/statesampler_fast.pyx | 11 +++-
sdks/python/apache_beam/transforms/async_dofn.py | 4 +-
.../apache_beam/transforms/async_dofn_test.py | 47 ++++++++++++++
.../yaml/extended_tests/databases/iceberg.yaml | 54 +++++++++-------
sdks/python/apache_beam/yaml/integration_tests.py | 74 ++++++++++++++++++++++
30 files changed, 494 insertions(+), 87 deletions(-)
