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 65eaf45026e fix lint (#28917)
add 99c87a2c68b Updates the Transform Service to accept Python extra
packages through the Java API (#28783)
add 88139bdc9a0 Retrieve workflow runs for GA Post-Commits Status
dashboard (#28844)
add e3c1591bbb8 Bump google.golang.org/grpc from 1.58.2 to 1.58.3 in /sdks
(#28938)
add 62efb967884 Bump golang.org/x/net from 0.16.0 to 0.17.0 in /sdks
(#28939)
add d437afab961 Run self-assign and pr-updates only in create event
(#28928)
add a54afde4a05 Fix missing backslash in arguments of job (#28942)
add e56d1a1157b Enable missing-timeout pylint check (#28920)
add 9cdcb036cc9 move nested windmill state classes to top level files and
organize di… (#28506)
add 6a456f04b68 Add user counters and msec metrics to prism UI. (#28929)
add 2bd23b16666 Add counter for MLTransform and data processing transforms
(#28927)
add c62a81b1c57 Reapply "Populate top-level display data in yaml main.
(#28512)"
add de48383bdca Fix typo in docstring.
add b82dd4849e4 Merge pull request #28931 from robertwb/display-data
add 7a1245d4011 Bump github.com/google/go-cmp from 0.5.9 to 0.6.0 in /sdks
(#28940)
add 2bfcb9fda37 Remove unnecessary a space character that got through
Javadoc CI ;) (#28863)
add aedfa461fb3 [#20970] Fix gRPC leak by closing ResidualSource at
BoundedToUnboundedSourceAdapter.Reader#init() in Dataflow worker (#28548)
add bd46c76dd08 Bump snappy-java version to 1.1.10.4 (#28655)
add ebad3deb5a0 Add GitHub Workflow Replacements for Jenkins
job_LoadTests_Python_CoGBK subgroup (#28764)
add dfdbcb9006b Add GitHub Workflow Replacements for Jenkins
job_LoadTests_Java_CoGBK subgroup (#28742)
add 09f30537015 Add GitHub Workflow Replacements for Jenkins
job_LoadTests_Python_SideInput_Dataflow_Batch (#28826)
add 6bab4b57992 Add Community Metrics Prober workflow (#28842)
add 104c10b3ee5 [RRIO] Create Caller and SetupTeardown interfaces (#28905)
add e8e38145d96 Setup Java 21 container (#28833)
add 9c75db4760c [YAML] Avro format for PubSub. (#28899)
No new revisions were added by this update.
Summary of changes:
.../beam_LoadTests_Java_CoGBK_Dataflow_Batch.yml | 114 +
...s_Java_CoGBK_Dataflow_V2_Batch_JavaVersions.yml | 132 +
...va_CoGBK_Dataflow_V2_Streaming_JavaVersions.yml | 132 +
...s_Java_CoGBK_SparkStructuredStreaming_Batch.yml | 114 +
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java11.yml | 14 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java17.yml | 14 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java11.yml | 14 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java17.yml | 14 +-
.../beam_LoadTests_Python_CoGBK_Dataflow_Batch.yml | 127 +
...m_LoadTests_Python_CoGBK_Dataflow_Streaming.yml | 126 +
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 135 +
...m_LoadTests_Python_SideInput_Dataflow_Batch.yml | 186 ++
.../beam_PostCommit_Java_Examples_Dataflow_ARM.yml | 2 +-
...m_PostCommit_Java_Examples_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Dataflow_Java17.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java17.yml | 2 +-
...am_PostCommit_Java_Nexmark_Dataflow_V2_Java.yml | 2 +-
..._Python_ValidatesContainer_Dataflow_With_RC.yml | 4 +-
.../beam_PostCommit_TransformService_Direct.yml | 2 +-
...eam_PreCommit_Java_Examples_Dataflow_Java11.yml | 2 +-
...eam_PreCommit_Java_Examples_Dataflow_Java17.yml | 2 +-
.github/workflows/beam_PreCommit_SQL_Java11.yml | 2 +-
.github/workflows/beam_PreCommit_SQL_Java17.yml | 2 +-
...Java17.yml => beam_Prober_CommunityMetrics.yml} | 54 +-
...ava_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt | 27 +
.../java_CoGBK_Dataflow_Batch_100b_Single_Key.txt | 27 +
.../java_CoGBK_Dataflow_Batch_10kB.txt | 27 +
.../java_CoGBK_Dataflow_Batch_2MB.txt | 27 +
...taflow_V2_Streaming_Java_100b_Multiple_Keys.txt | 29 +
..._Dataflow_V2_Streaming_Java_100b_Single_Key.txt | 29 +
.../java_CoGBK_Dataflow_V2_Streaming_Java_10kB.txt | 29 +
.../java_CoGBK_Dataflow_V2_Streaming_Java_2MB.txt | 29 +
...tructuredStreaming_Batch_100b_Multiple_Keys.txt | 25 +
...rkStructuredStreaming_Batch_100b_Single_Key.txt | 25 +
...a_CoGBK_SparkStructuredStreaming_Batch_10kB.txt | 25 +
...va_CoGBK_SparkStructuredStreaming_Batch_2MB.txt | 25 +
...hon_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt | 28 +
...python_CoGBK_Dataflow_Batch_100b_Single_Key.txt | 28 +
.../python_CoGBK_Dataflow_Batch_10kB.txt | 28 +
.../python_CoGBK_Dataflow_Batch_2MB.txt | 28 +
...GBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt | 28 +
..._CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt | 28 +
.../python_CoGBK_Dataflow_Flink_Batch_10kB.txt | 28 +
...CoGBK_Dataflow_Streaming_100b_Multiple_Keys.txt | 30 +
...on_CoGBK_Dataflow_Streaming_100b_Single_Key.txt | 30 +
.../python_CoGBK_Dataflow_Streaming_10kB.txt | 30 +
.../python_CoGBK_Dataflow_Streaming_2MB.txt | 30 +
...taflow_Batch_10gb_1000window_first_iterable.txt | 30 +
...put_Dataflow_Batch_10gb_1000window_iterable.txt | 29 +
..._Dataflow_Batch_10gb_1window_first_iterable.txt | 29 +
...eInput_Dataflow_Batch_10gb_1window_iterable.txt | 28 +
...flow_Batch_1gb_1000window_1key_percent_dict.txt | 30 +
...low_Batch_1gb_1000window_99key_percent_dict.txt | 30 +
...ataflow_Batch_1gb_1window_1key_percent_dict.txt | 29 +
...taflow_Batch_1gb_1window_99key_percent_dict.txt | 29 +
...Input_Dataflow_Batch_1gb_1window_first_list.txt | 29 +
...n_SideInput_Dataflow_Batch_1gb_1window_list.txt | 28 +
.github/workflows/pr-bot-pr-updates.yml | 1 +
.github/workflows/self-assign.yml | 2 +-
.test-infra/jenkins/JavaTestProperties.groovy | 7 +-
.test-infra/jenkins/NexmarkBuilder.groovy | 4 +-
.../job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy | 2 +-
.../job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy | 2 +-
.../job_LoadTests_GBK_Dataflow_V2_Java11.groovy | 2 +-
.../job_LoadTests_GBK_Dataflow_V2_Java17.groovy | 2 +-
.../job_LoadTests_ParDo_Dataflow_V2_Java11.groovy | 2 +-
.../job_LoadTests_ParDo_Dataflow_V2_Java17.groovy | 2 +-
...tCommit_Java_Examples_Dataflow_V2_Java11.groovy | 2 +-
...tCommit_Java_Examples_Dataflow_V2_Java17.groovy | 2 +-
...job_PostCommit_Java_Jpms_Dataflow_Java17.groovy | 2 +-
.../job_PostCommit_Java_Jpms_Direct_Java17.groovy | 2 +-
.../job_PostCommit_TransformService_Direct.groovy | 2 +-
..._PreCommit_Java_Examples_Dataflow_Java11.groovy | 2 +-
.../jenkins/job_PreCommit_SQL_Java11.groovy | 2 +-
.../jenkins/job_PreCommit_SQL_Java17.groovy | 2 +-
..._Precommit_Java_Examples_Dataflow_Java17.groovy | 2 +-
.test-infra/metrics/docker-compose.yml | 5 +-
.test-infra/metrics/sync/github/requirements.txt | 6 +-
.test-infra/metrics/sync/github/sync_workflows.py | 400 +--
build.gradle.kts | 16 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 39 +-
.../runners/core/construction/Environments.java | 6 +-
.../core/construction/TransformUpgrader.java | 2 +-
.../UnboundedReadFromBoundedSource.java | 14 +-
.../core/construction/EnvironmentsTest.java | 6 +-
.../UnboundedReadFromBoundedSourceTest.java | 180 ++
.../google-cloud-dataflow-java/arm/build.gradle | 6 +-
runners/google-cloud-dataflow-java/build.gradle | 6 +-
.../beam/runners/dataflow/DataflowRunner.java | 7 +-
.../dataflow/worker/StreamingDataflowWorker.java | 2 +
.../worker/StreamingModeExecutionContext.java | 483 ++--
.../beam/runners/dataflow/worker/Weighers.java | 2 +-
.../dataflow/worker/WindmillStateInternals.java | 2830 --------------------
.../dataflow/worker/WorkerCustomSources.java | 7 +-
.../dataflow/worker/streaming/ActiveWorkState.java | 2 +-
.../worker/streaming/ComputationState.java | 2 +-
.../worker/windmill/state/CachingStateTable.java | 275 ++
.../worker/windmill/state/ConcatIterables.java | 55 +
.../dataflow/worker/windmill/state/IdTracker.java | 253 ++
.../worker/windmill/state/PagingIterable.java | 129 +
.../dataflow/worker/windmill/state/RangeCoder.java | 76 +
.../worker/windmill/state/RangeSetCoder.java | 46 +
.../state/SimpleWindmillState.java} | 33 +-
.../dataflow/worker/windmill/state/StateTag.java | 109 +
.../windmill/state/TimestampedValueWithId.java | 42 +
.../worker/windmill/state/ToIterableFunction.java | 79 +
.../windmill/state/ValuesAndContPosition.java | 46 +
.../state/WeightedList.java} | 45 +-
.../worker/windmill/state/WindmillBag.java | 209 ++
.../windmill/state/WindmillCombiningState.java | 170 ++
.../worker/windmill/state/WindmillMap.java | 449 ++++
.../worker/windmill/state/WindmillMultimap.java | 732 +++++
.../worker/windmill/state/WindmillOrderedList.java | 305 +++
.../worker/windmill/state/WindmillSet.java | 146 +
.../worker/windmill/state/WindmillState.java | 68 +
.../{ => windmill/state}/WindmillStateCache.java | 338 +--
.../windmill/state/WindmillStateInternals.java | 171 ++
.../{ => windmill/state}/WindmillStateReader.java | 530 +---
.../worker/windmill/state/WindmillStateUtil.java | 51 +
.../worker/windmill/state/WindmillValue.java | 160 ++
.../windmill/state/WindmillWatermarkHold.java | 259 ++
.../worker/windmill/state/WrappedFuture.java | 64 +
.../worker/StreamingModeExecutionContextTest.java | 2 +
.../worker/streaming/ActiveWorkStateTest.java | 2 +-
.../state}/WindmillStateCacheTest.java | 135 +-
.../state}/WindmillStateInternalsTest.java | 282 +-
.../state}/WindmillStateReaderTest.java | 6 +-
runners/spark/spark_runner.gradle | 5 +-
sdks/go.mod | 6 +-
sdks/go.sum | 11 +-
sdks/go/pkg/beam/runners/prism/internal/web/web.go | 40 +-
sdks/java/container/Dockerfile | 3 +-
sdks/java/container/common.gradle | 14 +-
.../java/container/java21/build.gradle | 17 +-
sdks/java/container/java21/option-jamm.json | 12 +
.../extensions/python/PythonExternalTransform.java | 39 +-
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 2 +-
sdks/java/io/rrio/build.gradle | 7 +-
.../apache/beam/io/requestresponseio/Caller.java | 10 +-
.../beam/io/requestresponseio/SetupTeardown.java | 17 +-
.../UserCodeExecutionException.java | 21 +-
.../requestresponseio/UserCodeQuotaException.java | 33 +-
.../UserCodeTimeoutException.java | 22 +-
.../beam/io/requestresponseio/package-info.java | 5 +-
.../java/org/apache/beam/io/rrio/CallerTest.java | 126 +
.../org/apache/beam/io/rrio/SetupTeardownTest.java | 132 +
sdks/java/testing/jpms-tests/build.gradle | 21 +-
sdks/java/testing/test-utils/build.gradle | 29 +-
.../testutils/jvmverification/JvmVerification.java | 16 +-
sdks/java/transform-service/docker-compose/.env | 8 +
.../docker-compose/docker-compose.yml | 3 +-
sdks/java/transform-service/launcher/build.gradle | 3 +
.../launcher/TransformServiceLauncher.java | 135 +-
.../launcher/TransformServiceLauncherTest.java | 185 ++
.../sdk/transformservice/ExpansionService.java | 114 +-
.../sdk/transformservice/ExpansionServiceTest.java | 7 +-
sdks/python/.pylintrc | 1 -
sdks/python/apache_beam/ml/transforms/base.py | 39 +-
sdks/python/apache_beam/ml/transforms/base_test.py | 25 +
sdks/python/apache_beam/pipeline.py | 28 +-
.../portability/flink_uber_jar_job_server.py | 4 +-
.../testing/analyzers/github_issues_utils.py | 20 +-
.../testing/benchmarks/nexmark/nexmark_launcher.py | 3 +-
.../testing/load_tests/load_test_metrics_utils.py | 3 +-
sdks/python/apache_beam/transforms/display.py | 23 +-
.../utils/transform_service_launcher.py | 14 +
sdks/python/apache_beam/yaml/main.py | 17 +-
sdks/python/apache_beam/yaml/yaml_io.py | 21 +
sdks/python/apache_beam/yaml/yaml_io_test.py | 68 +
sdks/python/expansion-service-container/boot.go | 102 +-
settings.gradle.kts | 1 +
website/www/site/content/en/roadmap/java-sdk.md | 6 +-
172 files changed, 8519 insertions(+), 4362 deletions(-)
create mode 100644
.github/workflows/beam_LoadTests_Java_CoGBK_Dataflow_Batch.yml
create mode 100644
.github/workflows/beam_LoadTests_Java_CoGBK_Dataflow_V2_Batch_JavaVersions.yml
create mode 100644
.github/workflows/beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_JavaVersions.yml
create mode 100644
.github/workflows/beam_LoadTests_Java_CoGBK_SparkStructuredStreaming_Batch.yml
create mode 100644
.github/workflows/beam_LoadTests_Python_CoGBK_Dataflow_Batch.yml
create mode 100644
.github/workflows/beam_LoadTests_Python_CoGBK_Dataflow_Streaming.yml
create mode 100644
.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml
create mode 100644
.github/workflows/beam_LoadTests_Python_SideInput_Dataflow_Batch.yml
copy .github/workflows/{beam_PostCommit_Java_Jpms_Direct_Java17.yml =>
beam_Prober_CommunityMetrics.yml} (58%)
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_Batch_100b_Single_Key.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_Batch_10kB.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_Batch_2MB.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_100b_Multiple_Keys.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_100b_Single_Key.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_10kB.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_2MB.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_SparkStructuredStreaming_Batch_100b_Multiple_Keys.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_SparkStructuredStreaming_Batch_100b_Single_Key.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_SparkStructuredStreaming_Batch_10kB.txt
create mode 100644
.github/workflows/load-tests-job-configs/java_CoGBK_SparkStructuredStreaming_Batch_2MB.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Batch_100b_Single_Key.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Batch_10kB.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Batch_2MB.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Flink_Batch_10kB.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Streaming_100b_Multiple_Keys.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Streaming_100b_Single_Key.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Streaming_10kB.txt
create mode 100644
.github/workflows/load-tests-job-configs/python-cogbk/python_CoGBK_Dataflow_Streaming_2MB.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_10gb_1000window_first_iterable.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_10gb_1000window_iterable.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_10gb_1window_first_iterable.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_10gb_1window_iterable.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_1gb_1000window_1key_percent_dict.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_1gb_1000window_99key_percent_dict.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_1gb_1window_1key_percent_dict.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_1gb_1window_99key_percent_dict.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_1gb_1window_first_list.txt
create mode 100644
.github/workflows/load-tests-job-configs/python_SideInput_Dataflow_Batch_1gb_1window_list.txt
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateInternals.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/CachingStateTable.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/ConcatIterables.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/IdTracker.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/PagingIterable.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/RangeCoder.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/RangeSetCoder.java
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{Weighers.java
=> windmill/state/SimpleWindmillState.java} (50%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/StateTag.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/TimestampedValueWithId.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/ToIterableFunction.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/ValuesAndContPosition.java
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{Weighers.java
=> windmill/state/WeightedList.java} (53%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillCombiningState.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMap.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMultimap.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillOrderedList.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillSet.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillState.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateCache.java (92%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateInternals.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateReader.java (70%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateUtil.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WrappedFuture.java
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateCacheTest.java (75%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateInternalsTest.java (97%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateReaderTest.java (99%)
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/container/java21/build.gradle (59%)
create mode 100644 sdks/java/container/java21/option-jamm.json
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/Caller.java
(68%)
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/SetupTeardown.java
(54%)
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeExecutionException.java
(55%)
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/Weighers.java
=>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeQuotaException.java
(54%)
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeTimeoutException.java
(54%)
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/package-info.java
(84%)
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/rrio/CallerTest.java
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/rrio/SetupTeardownTest.java
create mode 100644
sdks/java/transform-service/launcher/src/test/java/org/apache/beam/sdk/transformservice/launcher/TransformServiceLauncherTest.java
