This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/sdks/github.com/docker/docker-27.1.1incompatible
in repository https://gitbox.apache.org/repos/asf/beam.git
discard b2d7016ef88 Bump github.com/docker/docker in /sdks
add 0b4b8ea9423 Handle rc container in
_update_container_image_for_dataflow (#32049)
add d96fa7d4009 Add some large model troubleshooting steps (#31862)
add bf42a8153af [#32064] Keep elements heap in sequence order. (#32065)
add 7e750873152 Update top_wikipedia_sessions to be more idiomatic with
beam.Map. (#32041)
add ca744ae9f65 Add WorkProvider interfaces and implementations (#31883)
add bfc64d5c14a Fix error when ActiveWorkRefresher processed empty
heartbeat map. (#32078)
add 80ae93217c5 Minor optimization for the common case of merging empty
string sets. (#31803)
add 5b2bfe96f83 [Prism] Enable an artifact resolver for the Prism runner
(#32058)
add fb49e9644a4 Fix load test dataproc cluster name exceeded allowed
length (#32062)
add c60623524ae Beam Website Updates for 2.58.0 Release (#31925)
add d09c3237c8a Added support for the TOKENLIST type in Spanner (#32038)
add e9b5dc69532 Enforce java.nio.charset.StandardCharsets against guava
Charsets (#32083)
add 99a23830037 Enable artifact staging during Prism Runner lifecycle
(#32084)
add 741facf0099 Bump github.com/docker/docker in /sdks (#32046)
add 5f69397ceb4 Bump github.com/docker/docker in /sdks
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 (b2d7016ef88)
\
N -- N -- N
refs/heads/dependabot/go_modules/sdks/github.com/docker/docker-27.1.1incompatible
(5f69397ceb4)
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:
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 2 +-
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 2 +-
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 2 +-
CHANGES.md | 21 +-
.../kafkatopubsub/transforms/FormatTransform.java | 5 +-
.../beam/runners/core/metrics/StringSetData.java | 17 +-
.../streaming/io/StreamingImpulseSource.java | 5 +-
.../runners/flink/FlinkJobServerDriverTest.java | 12 +-
.../FlinkPipelineExecutionEnvironmentTest.java | 4 +-
.../beam/runners/flink/FlinkSubmissionTest.java | 4 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 9 +-
.../wrappers/streaming/FlinkKeyUtilsTest.java | 4 +-
.../dataflow/DataflowPipelineTranslator.java | 7 +-
.../dataflow/worker/StreamingDataflowWorker.java | 342 ++++++++-------------
.../beam/runners/dataflow/worker/graph/Nodes.java | 6 +-
.../FanOutStreamingEngineWorkerHarness.java} | 63 ++--
.../harness/SingleSourceWorkerHarness.java | 284 +++++++++++++++++
.../harness}/StreamingEngineConnectionState.java | 2 +-
.../harness/StreamingWorkerHarness.java} | 17 +-
.../harness}/WindmillStreamSender.java | 20 +-
.../windmill/client/grpc/ChannelzServlet.java | 27 +-
.../client/grpc/GetWorkResponseChunkAssembler.java | 139 +++++++++
.../client/grpc/GrpcDirectGetWorkStream.java | 148 +++------
.../windmill/client/grpc/GrpcDispatcherClient.java | 4 +-
.../windmill/client/grpc/GrpcGetWorkStream.java | 131 ++------
.../worker/windmill/work/WorkItemScheduler.java | 4 -
.../work/budget/EvenGetWorkBudgetDistributor.java | 27 +-
.../work/budget/GetWorkBudgetDistributor.java | 5 +-
...tDistributor.java => GetWorkBudgetSpender.java} | 21 +-
.../windmill/work/refresh/ActiveWorkRefresher.java | 3 +
.../worker/StreamingDataflowWorkerTest.java | 2 +-
.../FanOutStreamingEngineWorkerHarnessTest.java} | 40 +--
.../harness}/WindmillStreamSenderTest.java | 5 +-
.../worker/GroupingShuffleEntryIteratorTest.java | 7 +-
.../windmill/client/grpc/ChannelzServletTest.java | 6 +-
.../client/grpc/GrpcWindmillServerTest.java | 12 +-
.../windmill/state/WindmillStateInternalsTest.java | 11 +-
.../windmill/state/WindmillStateReaderTest.java | 8 +-
.../budget/EvenGetWorkBudgetDistributorTest.java | 126 +++-----
.../work/refresh/ActiveWorkRefresherTest.java | 38 ++-
.../artifact/ArtifactStagingService.java | 4 +-
.../fnexecution/state/StateRequestHandlers.java | 5 +-
.../artifact/ArtifactRetrievalServiceTest.java | 4 +-
.../portability/testing/TestUniversalRunner.java | 5 +-
runners/prism/java/build.gradle | 1 +
.../beam/runners/prism/PrismArtifactResolver.java | 110 +++++++
.../beam/runners/prism/PrismArtifactStager.java | 173 +++++++++++
.../runners/prism/PrismArtifactResolverTest.java | 45 +++
.../runners/prism/PrismArtifactStagerTest.java | 143 +++++++++
.../prism/internal/engine/elementmanager.go | 15 +-
.../beam/runners/prism/internal/engine/timers.go | 1 +
.../main/resources/beam/checkstyle/checkstyle.xml | 8 +
.../providers/LoggingTransformProvider.java | 4 +-
.../sdk/transforms/errorhandling/BadRecord.java | 6 +-
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 6 +-
.../transforms/resourcehints/ResourceHints.java | 8 +-
.../beam/sdk/coders/StructuralByteArrayTest.java | 10 +-
.../org/apache/beam/sdk/io/FileBasedSinkTest.java | 2 +-
.../java/org/apache/beam/sdk/io/FileIOTest.java | 6 +-
.../org/apache/beam/sdk/io/TFRecordIOTest.java | 7 +-
.../org/apache/beam/sdk/io/TextIOReadTest.java | 8 +-
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 6 +-
.../beam/sdk/io/TextRowCountEstimatorTest.java | 10 +-
.../org/apache/beam/sdk/io/WriteFilesTest.java | 5 +-
.../sdk/options/PipelineOptionsFactoryTest.java | 24 +-
.../beam/sdk/schemas/SchemaTranslationTest.java | 5 +-
.../BufferedElementCountingOutputStreamTest.java | 6 +-
.../sdk/util/ExposedByteArrayInputStreamTest.java | 6 +-
.../sdk/util/ExposedByteArrayOutputStreamTest.java | 4 +-
.../beam/sdk/util/SerializableUtilsTest.java | 4 +-
.../expansion/service/ExpansionServiceTest.java | 4 +-
.../avro/AvroGenericCoderTranslator.java | 6 +-
.../beam/sdk/extensions/avro/io/AvroIOTest.java | 6 +-
.../extensions/python/PythonExternalTransform.java | 5 +-
.../beam/sdk/extensions/python/PythonService.java | 5 +-
sdks/java/extensions/sql/jdbc/build.gradle | 2 +-
.../beam/sdk/extensions/sql/jdbc/BeamSqlLine.java | 6 +-
.../meta/provider/text/TextTableProviderTest.java | 20 +-
.../beam/sdk/io/clickhouse/ClickHouseWriter.java | 4 +-
.../io/contextualtextio/ContextualTextIOTest.java | 16 +-
.../beam/sdk/io/gcp/spanner/SpannerSchema.java | 3 +
.../PubsubReadSchemaTransformProviderTest.java | 6 +-
.../beam/sdk/io/gcp/spanner/SpannerSchemaTest.java | 4 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 6 +-
.../org/apache/beam/sdk/tpcds/QueryReader.java | 4 +-
.../apache/beam/sdk/tpcds/SqlTransformRunner.java | 4 +-
.../beam/sdk/tpcds/TableSchemaJSONLoader.java | 4 +-
.../launcher/TransformServiceLauncherTest.java | 10 +-
.../examples/complete/top_wikipedia_sessions.py | 34 +-
.../complete/top_wikipedia_sessions_test.py | 2 +
.../runners/dataflow/internal/apiclient.py | 6 +
.../runners/dataflow/internal/apiclient_test.py | 37 +++
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.58.0.md | 130 ++++++++
.../en/documentation/ml/large-language-modeling.md | 50 ++-
.../www/site/content/en/get-started/downloads.md | 13 +-
96 files changed, 1771 insertions(+), 851 deletions(-)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{windmill/client/grpc/StreamingEngineClient.java
=> streaming/harness/FanOutStreamingEngineWorkerHarness.java} (91%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/SingleSourceWorkerHarness.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{windmill/client/grpc
=> streaming/harness}/StreamingEngineConnectionState.java (97%)
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{windmill/work/budget/GetWorkBudgetDistributor.java
=> streaming/harness/StreamingWorkerHarness.java} (59%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{windmill/client/grpc
=> streaming/harness}/WindmillStreamSender.java (93%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GetWorkResponseChunkAssembler.java
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/{GetWorkBudgetDistributor.java
=> GetWorkBudgetSpender.java} (60%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{windmill/client/grpc/StreamingEngineClientTest.java
=> streaming/harness/FanOutStreamingEngineWorkerHarnessTest.java} (93%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{windmill/client/grpc
=> streaming/harness}/WindmillStreamSenderTest.java (97%)
create mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismArtifactResolver.java
create mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismArtifactStager.java
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismArtifactResolverTest.java
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismArtifactStagerTest.java
create mode 100644 website/www/site/content/en/blog/beam-2.58.0.md
