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 6b55c145853 Update Dataflow Proto (#38540)
add bb0bc772d4e Bump google.golang.org/api from 0.279.0 to 0.280.0 in
/sdks (#38563)
add ef703f65aff Bump cloud.google.com/go/datastore from 1.23.0 to 1.24.0
in /sdks (#38564)
add f22400a21a9 [Dataflow Streaming] Add experiment to use trigger state
to know if a window is new and optimize reads (#37574)
add 2105eaa4d23 Disable grpc fork support on some test suites. (#38566)
add c33bc972f15 Fix race condition in UserPipelineTracker.clear() and
various problems (#38537)
add 582bb452985 [Java SDK] Infer Beam logical types for JSR-310 and UUID
fields (#38194)
add ba63482cad5 introduce private method to remove clones (#38245)
add 2375fed9735 Refresh Iceberg partition specs periodically (#38408)
add 290e3721b50 WriteToJson - force num_shards (#38484)
No new revisions were added by this update.
Summary of changes:
.../it/gcp/bigquery/BigQueryResourceManager.java | 42 +++---
.../apache/beam/runners/core/ReduceFnRunner.java | 49 +++++-
.../apache/beam/runners/core/WatermarkHold.java | 17 +++
.../core/triggers/FinishedTriggersBitSet.java | 14 ++
.../core/triggers/TriggerStateMachineRunner.java | 43 ++++--
.../beam/runners/core/ReduceFnRunnerTest.java | 58 +++++++
.../apache/beam/runners/core/ReduceFnTester.java | 13 ++
.../triggers/TriggerStateMachineRunnerTest.java | 117 +++++++++++++++
.../windmill/state/WindmillWatermarkHold.java | 94 ++++++++----
.../windmill/state/WindmillStateInternalsTest.java | 167 ++++++++++++++++++++-
sdks/go.mod | 10 +-
sdks/go.sum | 20 +--
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 128 ++++++++++++++++
.../sdk/schemas/utils/StaticSchemaInference.java | 19 ++-
.../apache/beam/sdk/state/WatermarkHoldState.java | 10 ++
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 83 ++++++++++
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 122 +++++++++++++++
.../beam/sdk/schemas/transforms/ConvertTest.java | 99 ++++++++++++
.../beam/sdk/schemas/utils/JavaBeanUtilsTest.java | 10 ++
.../beam/sdk/schemas/utils/POJOUtilsTest.java | 32 ++++
.../beam/sdk/schemas/utils/TestJavaBeans.java | 89 +++++++++++
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 118 +++++++++++++++
.../extensions/avro/schemas/utils/AvroUtils.java | 87 ++++++-----
.../iceberg/AssignDestinationsAndPartitions.java | 47 +++++-
sdks/python/apache_beam/dataframe/io.py | 20 ++-
.../runners/interactive/interactive_environment.py | 10 +-
.../runners/interactive/user_pipeline_tracker.py | 109 ++++++++------
.../interactive/user_pipeline_tracker_test.py | 48 ++++++
.../runners/portability/portable_runner_test.py | 17 +++
.../apache_beam/utils/subprocess_server_test.py | 17 +++
30 files changed, 1531 insertions(+), 178 deletions(-)
create mode 100644
runners/core-java/src/test/java/org/apache/beam/runners/core/triggers/TriggerStateMachineRunnerTest.java
