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 020707df9d6 Fix flaky Go tests (#40296)
add 9094bda60bc Bump github/codeql-action from 4.38.1 to 4.38.2 (#40307)
add d6b2e36422d Bump cloud.google.com/go/datastore from 1.26.0 to 1.27.0
in /sdks (#40306)
add 4a59ed31e2d Bump github.com/aws/aws-sdk-go-v2 from 1.47.0 to 1.47.1 in
/sdks (#40310)
add ccb1c058d0d Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#40305)
add 3e69022449d [#20502] Remove nullness suppressions from the direct-java
runner (#40295)
add 5c2ba441ba8 [BigQueryIO] Improve error message when BigQuery API is
reported as not enabled (#40233)
add 4b2d65efd28 Adds support to UngroupedWindmillReader for empty element
metadata. (#40224)
add c3d18ba40a8 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#40308)
add c0c60ecfbf4 Bump cloud.google.com/go/bigquery from 1.84.0 to 1.85.0 in
/sdks (#40309)
add 0e258d093b6 bump kafka-client (#40311)
add 9d25859125d [Website] Add Asgarde, an error handling library, to the
3rd party Java extensions (#40268)
add 3c41bd28c9a [PR Bot] Best-effort assign reviewers via GitHub API
(#40313)
add 5fa6ef8a3b4 [PR Bot] Pause review reminders on draft PRs and update
Next Action state (#40314)
add 94972054878 Route the remaining GCS calls through GcsUtilV2 when
enabled (#40273)
add 092c918dbe2 remove build checks (#40318)
add b4db8d2a11d Fix documentation typos across website, contributor docs,
and Go SDK docs (#40316)
No new revisions were added by this update.
Summary of changes:
.github/workflows/codeql.yml | 7 +-
.github/workflows/pr-bot-pr-updates.yml | 2 +-
contributor-docs/python-tips.md | 2 +-
contributor-docs/release-guide.md | 8 +-
.../apache/beam/it/gcp/storage/ParquetIOLT.java | 47 +-
.../direct/BoundedReadEvaluatorFactory.java | 21 +-
.../beam/runners/direct/CloningBundleFactory.java | 11 +-
.../beam/runners/direct/CommittedResult.java | 3 -
.../direct/CopyOnAccessInMemoryStateInternals.java | 13 +-
.../runners/direct/DirectExecutionContext.java | 16 +-
.../apache/beam/runners/direct/DirectGraph.java | 10 +-
.../beam/runners/direct/DirectGraphVisitor.java | 14 +-
.../apache/beam/runners/direct/DirectMetrics.java | 10 +-
.../apache/beam/runners/direct/DirectRunner.java | 13 +-
.../runners/direct/DirectWriteViewVisitor.java | 18 +-
.../beam/runners/direct/DisplayDataValidator.java | 11 +-
.../beam/runners/direct/EvaluationContext.java | 26 +-
.../direct/ExecutorServiceParallelExecutor.java | 33 +-
.../direct/GroupAlsoByWindowEvaluatorFactory.java | 17 +-
.../direct/GroupByKeyOnlyEvaluatorFactory.java | 7 +-
.../direct/ImmutabilityCheckingBundleFactory.java | 12 +-
.../direct/ImmutabilityEnforcementFactory.java | 9 +-
.../runners/direct/ImmutableListBundleFactory.java | 12 +-
.../runners/direct/KeyedPValueTrackingVisitor.java | 11 +-
.../beam/runners/direct/MultiStepCombine.java | 6 +-
.../apache/beam/runners/direct/ParDoEvaluator.java | 13 +-
.../beam/runners/direct/ParDoEvaluatorFactory.java | 7 +-
.../beam/runners/direct/PipelineExecutor.java | 3 +-
.../beam/runners/direct/QuiescenceDriver.java | 27 +-
.../beam/runners/direct/RootProviderRegistry.java | 3 +-
.../beam/runners/direct/SideInputContainer.java | 30 +-
.../SplittableProcessElementsEvaluatorFactory.java | 12 +-
.../direct/StatefulParDoEvaluatorFactory.java | 27 +-
.../beam/runners/direct/StepTransformResult.java | 10 +-
.../runners/direct/TestStreamEvaluatorFactory.java | 3 +-
.../runners/direct/TransformEvaluatorRegistry.java | 6 +-
.../runners/direct/TransformExecutorServices.java | 6 +-
.../direct/UnboundedReadEvaluatorFactory.java | 9 +-
.../runners/direct/WatermarkCallbackExecutor.java | 24 +-
.../beam/runners/direct/WatermarkManager.java | 140 ++++--
.../runners/direct/WindowEvaluatorFactory.java | 2 +-
.../dataflow/worker/UngroupedWindmillReader.java | 40 +-
.../worker/UngroupedWindmillReaderTest.java | 209 ++++++++
scripts/ci/pr-bot/README.md | 6 +-
scripts/ci/pr-bot/findPrsNeedingAttention.ts | 19 +-
scripts/ci/pr-bot/processNewPrs.ts | 5 +
scripts/ci/pr-bot/processPrUpdate.ts | 30 +-
scripts/ci/pr-bot/shared/constants.ts | 1 +
scripts/ci/pr-bot/shared/githubUtils.ts | 25 +
scripts/ci/pr-bot/shared/userCommand.ts | 5 +
scripts/ci/pr-bot/test/githubUtilsTest.ts | 51 +-
sdks/go.mod | 36 +-
sdks/go.sum | 72 +--
sdks/go/BUILD.md | 2 +-
sdks/go/README.md | 2 +-
sdks/go/pkg/beam/runners/prism/README.md | 18 +-
sdks/go/pkg/beam/runners/prism/internal/README.md | 44 +-
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 218 +++++++-
.../beam/sdk/extensions/gcp/util/GcsUtilV2.java | 94 +++-
.../beam/sdk/extensions/gcp/util/GcsUtilTest.java | 559 +++++++++++++++++++++
.../sdk/extensions/gcp/util/GcsUtilV2Test.java | 12 +
sdks/java/io/expansion-service/build.gradle | 2 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 34 +-
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 98 ++++
.../www/site/content/en/contribute/dependencies.md | 2 +-
.../dsls/sql/extensions/create-external-table.md | 2 +-
.../en/documentation/io/built-in/snowflake.md | 2 +-
.../content/en/documentation/io/io-standards.md | 4 +-
.../site/content/en/documentation/runners/prism.md | 4 +-
.../en/documentation/sdks/java-thirdparty.md | 45 ++
.../content/en/documentation/sdks/typescript.md | 2 +-
.../en/documentation/sdks/yaml-providers.md | 2 +-
.../python/elementwise/enrichment-milvus.md | 2 +-
.../transforms/python/elementwise/mltransform.md | 2 +-
.../python/elementwise/runinference-sklearn.md | 2 +-
.../transforms/python/elementwise/runinference.md | 2 +-
.../en/get-started/mobile-gaming-example.md | 2 +-
77 files changed, 1863 insertions(+), 453 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/UngroupedWindmillReaderTest.java
