This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch flink2-pvr
in repository https://gitbox.apache.org/repos/asf/beam.git
omit 9df67132e7a Exercise Flink PVR tests
omit f504c5309bc Revert "[Python] Add take(n) convenience for PCollection
(#37470)" (#37493)
omit d6920de30fe Add schedule trigger to Playground PreCommit (#37519)
omit e2be9fd8e36 Plumb custom batch parameters for autosharding from
WriteFiles to FileIO. (#37463)
omit 15ba4874d72 Add schedule trigger for beam playground precommit (#37518)
omit beec6a3e156 Update logback version to address vulnerability (#37501)
omit 5240736a9bc [#37279] Document Ubuntu 24.04 Python version requirements
(#37297)
omit 4e76198555e fix spotless (#37508)
omit fed1b551c35 Add support for tagged output type hints. (#37434)
omit 99e48681a03 Increment PyArrow Bounds (#37503)
omit c1ecbb9eeb1 Fix linting/compilation violation (#37505)
omit 4e218f0183e Add model manager that automatically manage model across
processes (#37113)
add 8ccd13e40b6 [Flink 2.0] Exercise validate runner test for classic
Flink runner
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 (9df67132e7a)
\
N -- N -- N refs/heads/flink2-pvr (8ccd13e40b6)
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:
.github/workflows/README.md | 1 -
.github/workflows/beam_Playground_Precommit.yml | 6 +-
.../beam_PostCommit_Java_PVR_Flink_Batch.yml | 8 +-
.../beam_PostCommit_Java_PVR_Flink_Streaming.yml | 8 +-
.../beam_PostCommit_Java_ValidatesRunner_Flink.yml | 8 +-
.github/workflows/stale.yml | 1 -
CHANGES.md | 4 +
CONTRIBUTING.md | 5 +-
.../windmill/state/WindmillTagEncodingV2Test.java | 8 +-
sdks/java/core/build.gradle | 1 +
.../main/java/org/apache/beam/sdk/io/FileIO.java | 66 --
.../java/org/apache/beam/sdk/io/FileIOTest.java | 139 ----
.../io/components/deadletterqueue/DLQRouter.java | 21 +-
.../deadletterqueue/sinks/ThrowingSink.java | 3 +-
.../components/throttling/ThrottlingSignaler.java | 11 +-
.../components/deadletterqueue/DLQRouterTest.java | 30 +-
sdks/java/io/expansion-service/build.gradle | 7 +-
sdks/python/apache_beam/io/parquetio_test.py | 2 +-
.../apache_beam/ml/inference/model_manager.py | 747 ---------------------
.../apache_beam/ml/inference/model_manager_test.py | 622 -----------------
sdks/python/apache_beam/pvalue.py | 31 +-
sdks/python/apache_beam/transforms/core.py | 41 +-
sdks/python/apache_beam/transforms/ptransform.py | 28 +-
sdks/python/apache_beam/transforms/util.py | 74 +-
sdks/python/apache_beam/transforms/util_test.py | 39 ++
sdks/python/apache_beam/typehints/decorators.py | 182 +----
.../apache_beam/typehints/decorators_test.py | 125 ----
.../typehints/tagged_output_typehints_test.py | 356 ----------
.../python/apache_beam/typehints/typehints_test.py | 2 +-
sdks/python/setup.py | 2 +-
sdks/python/tox.ini | 19 +-
31 files changed, 236 insertions(+), 2361 deletions(-)
delete mode 100644 sdks/python/apache_beam/ml/inference/model_manager.py
delete mode 100644 sdks/python/apache_beam/ml/inference/model_manager_test.py
delete mode 100644
sdks/python/apache_beam/typehints/tagged_output_typehints_test.py
