You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2025/06/17 22:52:07 UTC
(beam) branch dependabot/pip/playground/infrastructure/protobuf-4.25.8 updated (2cd5a6cc3d6 -> 0df9e111dee)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/pip/playground/infrastructure/protobuf-4.25.8
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 2cd5a6cc3d6 Bump protobuf from 4.21.12 to 4.25.8 in /playground/infrastructure
add a2e936b21b5 try buildah to replace kaniko (#35289)
add 22097177411 Adding error handler for SpannerReadSchemaTransformProvider and missi… (#35241)
add b995adab43f requests vulnerability. (#35308)
add e5e07c5100c [IcebergIO] create custom java container image for tests (#35307)
add 297ba99e96e add streaming support to iobase (python) (#35137)
add a9339063c94 Fix Spotbugs (#35313)
add d50b4e49981 use Median Absolute Deviation for the perf alerts (#35294)
add 71073a0ec12 Reverts #35202 (#35306)
add 730388a688b Fix `beam.Filter` type hints for case where filter_fn specifies output type hint but not input type hint (#35283)
add 0e4b2a364f4 [Beam SQL] Change SET CATALOG to USE CATALOG (#35314)
add 6c52b0c375a Unbreak Playground CI nightly suite (#35330)
add 085962b1006 Update state doc 34905 (#35209)
add 2cd8d07cc2e Fix unstable output of periodic sequence due to precision error. (#35311)
add f4b677ce762 Update README.md (#35331)
add bc022baf217 Fix flaky precommit java test on prism caused by PR 35202 (#35336)
add a1b8c39f210 Blog: My Experience at Beam College 2025 (3rd Place Hackathon Winner) (#35315)
add c6605ef0221 Support runners other than DirectRunner for :examples:java:execute (#35262)
add bd86700fdd2 Dont exit execution loop before bundle is done (#35337)
add 7c1aa722ef4 Bump protobuf from 4.25.0 to 4.25.8 in /.test-infra/mock-apis (#35321)
add 0df9e111dee Bump protobuf from 4.21.12 to 4.25.8 in /playground/infrastructure
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 (2cd5a6cc3d6)
\
N -- N -- N refs/heads/dependabot/pip/playground/infrastructure/protobuf-4.25.8 (0df9e111dee)
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:
.../IO_Iceberg_Integration_Tests_Dataflow.json | 3 +-
...Iceberg_Managed_Integration_Tests_Dataflow.json | 2 +-
...tCommit_Python_ValidatesContainer_Dataflow.json | 2 +-
.github/trigger_files/beam_PostCommit_SQL.json | 2 +-
...Nexmark_Flink.json => beam_PreCommit_Java.json} | 2 +-
.github/workflows/README.md | 2 +-
.test-infra/mock-apis/build.gradle | 1 +
.test-infra/mock-apis/poetry.lock | 45 +--
CHANGES.md | 1 +
examples/java/build.gradle | 41 ++-
.../org/apache/beam/examples/KafkaStreaming.java | 6 +-
.../beam/examples/complete/TrafficRoutes.java | 8 +-
.../datatokenization/utils/SchemasUtils.java | 2 +
.../beam/examples/cookbook/TriggerExample.java | 7 +-
.../configuration/SubProcessConfiguration.java | 2 +
.../examples/kotlin/cookbook/TriggerExample.kt | 1 +
.../beam/it/common/utils/ResourceManagerUtils.java | 14 +-
.../core/metrics/ExecutionStateSampler.java | 2 +
.../beam/runners/flink/metrics/FileReporter.java | 1 +
.../dataflow/DataflowPTransformMatchers.java | 2 +
.../beam/runners/dataflow/DataflowRunner.java | 4 +-
.../samza/container/ContainerCfgLoader.java | 4 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 12 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 12 +-
.../src/main/resources/beam/spotbugs-filter.xml | 4 +
.../org/apache/beam/sdk/coders/CoderProviders.java | 2 +
.../org/apache/beam/sdk/coders/DefaultCoder.java | 2 +
.../transforms/resourcehints/ResourceHints.java | 2 +-
.../beam/sdk/extensions/ml/AnnotateImages.java | 3 +-
.../extensions/sql/src/main/codegen/config.fmpp | 7 +-
.../sql/src/main/codegen/includes/parserImpls.ftl | 8 +-
.../{SqlSetCatalog.java => SqlUseCatalog.java} | 12 +-
.../beam/sdk/extensions/sql/BeamSqlCliTest.java | 14 +-
.../sdk/extensions/sql/PubsubToBigqueryIT.java | 2 +-
.../beam/sdk/extensions/sql/PubsubToIcebergIT.java | 2 +-
.../meta/provider/iceberg/IcebergReadWriteIT.java | 4 +-
.../provider/iceberg/IcebergTableProviderTest.java | 2 +-
sdks/java/io/debezium/build.gradle | 1 -
.../beam/io/debezium/KafkaSourceConsumerFn.java | 2 +
.../SpannerReadSchemaTransformProvider.java | 92 +++++-
.../SpannerSchemaTransformProviderTest.java | 316 +++++++++++++++++++++
sdks/java/io/iceberg/build.gradle | 6 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 2 +
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 2 +
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 2 +
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 2 +-
.../apache/beam/sdk/io/snowflake/KeyPairUtils.java | 2 +
.../beam/sdk/io/synthetic/SyntheticOptions.java | 3 +
.../beam/sdk/io/synthetic/SyntheticStep.java | 2 +
sdks/java/testing/jpms-tests/build.gradle | 1 +
.../beam/sdk/nexmark/NexmarkConfiguration.java | 2 +
.../transforms/elementwise/pardo_dofn_methods.py | 2 +
sdks/python/apache_beam/io/iobase.py | 274 +++++++++++++++++-
sdks/python/apache_beam/ml/ts/util.py | 14 +-
sdks/python/apache_beam/ml/ts/util_test.py | 11 +
sdks/python/apache_beam/pipeline_test.py | 29 ++
.../runners/portability/sdk_container_builder.py | 16 +-
.../apache_beam/testing/analyzers/constants.py | 1 +
.../apache_beam/testing/analyzers/perf_analysis.py | 9 +-
.../testing/analyzers/perf_analysis_utils.py | 28 +-
sdks/python/apache_beam/transforms/core.py | 27 +-
sdks/python/apache_beam/transforms/userstate.py | 50 +++-
sdks/python/apache_beam/yaml/standard_io.yaml | 1 +
.../container/py310/base_image_requirements.txt | 96 ++++---
.../container/py311/base_image_requirements.txt | 96 ++++---
.../container/py312/base_image_requirements.txt | 98 ++++---
.../container/py39/base_image_requirements.txt | 92 +++---
sdks/python/setup.py | 2 +-
.../content/en/blog/beam-college-2025-anomaflow.md | 80 ++++++
.../content/en/documentation/programming-guide.md | 86 ++++++
website/www/site/data/authors.yml | 4 +
72 files changed, 1398 insertions(+), 297 deletions(-)
copy .github/trigger_files/{beam_PostCommit_Java_Nexmark_Flink.json => beam_PreCommit_Java.json} (82%)
rename sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/{SqlSetCatalog.java => SqlUseCatalog.java} (91%)
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerSchemaTransformProviderTest.java
create mode 100644 website/www/site/content/en/blog/beam-college-2025-anomaflow.md