This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch list-workflow
in repository https://gitbox.apache.org/repos/asf/beam.git
omit 84790b90373 Add a check to make sure GitHub action workflows are
listed in readme
add 39c7b46aecb Regenerate beam container image dependencies to include
newer version of grpc. (#37822)
add 4aff88ea91a Revert "[Dataflow Streaming] Prevent commit threads from
sharing commit streams" (#37873)
add 65179691f25 Fix maven archetype dependency for io-components
add 41b513e210c Merge pull request #37871 from Abacn/fix-maven-archtype
add 90c2ab28a26 [Gemini] Fix bad-unpacking pyrefly error (#37828)
add 0fb490f927f [ErrorProne] Enable EmptyCatch Error Prone check and
document ignored exceptions (#37754)
add babf20c99dc Adds validates runner post commit tests for Java streaming
worker on streaming engine (#37872)
add 1007f73c8e4 Update python dev container tag (#37853)
add fa9d19063ba SDF draining in dataflow runner v1 (#37831)
add 8c48120697e Enable error_prone UnnecessaryLongToIntConversion check
(#37783)
add 6f27015d3fb Add a check to make sure GitHub action workflows are
listed in readme
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (84790b90373)
\
N -- N -- N refs/heads/list-workflow (6f27015d3fb)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
...ValidatesRunner_Dataflow_Streaming_Engine.json} | 0
.github/workflows/README.md | 1 +
..._ValidatesRunner_Dataflow_Streaming_Engine.yml} | 15 ++++---
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 -
.../twitterstreamgenerator/TwitterConnection.java | 1 +
...TimeBoundedSplittableProcessElementInvoker.java | 5 +++
.../core/SplittableParDoViaKeyedWorkItems.java | 37 +++++++++++------
.../runners/core/SplittableParDoProcessFnTest.java | 46 +++++++++++++++++++++-
.../runners/flink/metrics/MetricsAccumulator.java | 1 +
runners/google-cloud-dataflow-java/build.gradle | 11 ++++++
.../dataflow/worker/StreamingDataflowWorker.java | 9 ++---
.../StreamingEngineComputationConfigFetcher.java | 2 +-
.../apache/beam/runners/prism/PrismExecutor.java | 2 +
.../TestSamzaRunnerWithTransformMetrics.java | 4 +-
.../metrics/TestSamzaTransformMetricsRegistry.java | 4 +-
.../org/apache/beam/sdk/transforms/DoFnTester.java | 7 +++-
.../org/apache/beam/sdk/values/WindowedValues.java | 2 +-
.../sdk/extensions/gcp/util/GceMetadataUtil.java | 1 +
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 20 +++++-----
.../io/aws2/common/AsyncBatchWriteHandlerTest.java | 1 +
.../gcp/bigtable/changestreams/dao/DaoFactory.java | 1 +
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 1 +
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 1 +
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 1 +
.../apache/beam/sdk/io/iceberg/FilterUtils.java | 1 +
.../org/apache/beam/sdk/io/pulsar/PulsarIOIT.java | 2 +-
.../org/apache/beam/io/requestresponse/Call.java | 2 +
.../apache/beam/io/requestresponse/Repeater.java | 1 +
.../EchoGRPCCallerWithSetupTeardown.java | 1 +
.../src/main/resources/archetype-resources/pom.xml | 6 +++
.../src/main/resources/archetype-resources/pom.xml | 6 +++
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
sdks/python/apache_beam/yaml/yaml_ml.py | 7 ++--
.../container/ml/py310/base_image_requirements.txt | 28 ++++++-------
.../container/ml/py310/gpu_image_requirements.txt | 24 +++++------
.../container/ml/py311/base_image_requirements.txt | 33 +++++++---------
.../container/ml/py311/gpu_image_requirements.txt | 29 +++++++-------
.../container/ml/py312/base_image_requirements.txt | 33 +++++++---------
.../container/ml/py312/gpu_image_requirements.txt | 29 +++++++-------
.../container/ml/py313/base_image_requirements.txt | 12 +++---
.../container/py310/base_image_requirements.txt | 14 +++----
.../container/py311/base_image_requirements.txt | 19 ++++-----
.../container/py312/base_image_requirements.txt | 19 ++++-----
.../container/py313/base_image_requirements.txt | 8 ++--
sdks/python/pyproject.toml | 3 ++
sdks/python/pyrefly.toml | 3 +-
sdks/python/setup.py | 25 ++++++++----
47 files changed, 295 insertions(+), 187 deletions(-)
copy
.github/trigger_files/{beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json
=> beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_Engine.json} (100%)
copy
.github/workflows/{beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.yml
=> beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_Engine.yml} (90%)
