This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/sdks/golang.org/x/text-0.22.0
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 3c0a600d983 Bump golang.org/x/text from 0.21.0 to 0.22.0 in /sdks
add 99e7bbf348c Fix Postcommit Java IO Performance tests workflow (#33915)
add 1798cd36754 Reduce frequency of issue report (#33906)
add 67c774dde01 Decrease load for Go GBK and CoGBK tests (#33898)
add 047715ee3e4 Change the period for checking if the workflow is flaky
(#33897)
add f03e0c0ad7b Move interactive-specific TestStreamService to interactive
protos. (#33858)
add 6cc98eea08e Add alloydb password secret to Python postcommit test
workflow. (#33927)
add 25425db913d Add unassign issue feature (#33924)
add 30a8c2dfca1 [AnomalyDetection] Add base classes and specifiable
protocol (#33845)
add 6bf8b737a51 Fix unsubscribe emails on Contact Us page (#33926)
add 5fd7b106915 Fix error in Dataflow Cost Benchmark README (#33930)
add c740e79f543 Update Python Dependencies (#33923)
add 66fbd581353 Add AlloyDB password to Xlang GCP and Direct Postcommit
workflows. (#33933)
add e1ab2e9e605 Skip BoundedTrie on Dataflow till service is have
BoundedTrie (#33921)
add fec1ab5360f Reduce Iceberg IT parallel forks (#33937)
add 99f5c9770ed fix git task/close workflow breakage (#33940)
add 0cc18a3a297 Do not run Typescript tests on windows-server-2019 runner
(#33941)
add 4cd211b5ec2 Improve docstring for fire_interval (#33936)
add f74ea9de6e8 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#33938)
add 2b18c281326 null arrays default to empty array (#33919)
add 6fcf1618788 [#31438] Non-processing time triggers pass w/accumulation.
(#33881)
add 7ac5bc43ecf Disable PreCommit Flink Container (#33956)
add 2acc9ccba34 Reenable PreCommit Flink Container after Fix cleanup
scripts (#33957)
add e66b64556a1 update pthon container (#33955)
add 2a0820a8309 sdks/go: utilize go-cmp package for comparison (#33922)
add 332a61d8481 Bump google.golang.org/api from 0.219.0 to 0.220.0 in
/sdks (#33961)
add 58b3032ee88 Bump golang.org/x/text from 0.21.0 to 0.22.0 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 (3c0a600d983)
\
N -- N -- N
refs/heads/dependabot/go_modules/sdks/golang.org/x/text-0.22.0 (58b3032ee88)
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/ACTIONS.md | 3 +-
.github/ISSUE_TEMPLATE/bug.yml | 2 +-
.github/ISSUE_TEMPLATE/failing_test.yml | 2 +-
.github/ISSUE_TEMPLATE/feature.yml | 2 +-
.github/ISSUE_TEMPLATE/task.yml | 2 +-
.github/autolabeler.yml | 2 +-
.../IO_Iceberg_Integration_Tests.json | 2 +-
...m_PostCommit_Java_ValidatesRunner_Dataflow.json | 3 +-
.../beam_LoadTests_Go_CoGBK_Flink_batch.yml | 4 +-
.../beam_LoadTests_Go_GBK_Flink_Batch.yml | 4 +-
.github/workflows/beam_PostCommit_Python.yml | 1 +
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml | 1 +
.../beam_PostCommit_Python_Xlang_Gcp_Direct.yml | 1 +
.../workflows/beam_PreCommit_Flink_Container.yml | 17 +-
.../beam_PreCommit_Java_GCP_IO_Direct.yml | 2 -
.../workflows/beam_PreCommit_Portable_Python.yml | 4 -
.../workflows/beam_PreCommit_Python_PVR_Flink.yml | 4 -
.../go_CoGBK_Flink_Batch_Reiteration_10KB.txt | 4 +-
.../go_CoGBK_Flink_Batch_Reiteration_2MB.txt | 4 +-
.../go_GBK_Flink_Batch_100b.txt | 2 +-
.../go_GBK_Flink_Batch_100kb.txt | 2 +-
.../go_GBK_Flink_Batch_Fanout_4.txt | 2 +-
.../go_GBK_Flink_Batch_Fanout_8.txt | 2 +-
.../go_GBK_Flink_Batch_Reiteration_10KB.txt | 2 +-
.github/workflows/reportGenerator.yml | 2 +-
.github/workflows/self-assign.yml | 14 +-
.github/workflows/typescript_tests.yml | 2 +-
.test-infra/dataproc/cleanup.sh | 3 +-
.../github/github_runs_prefetcher/code/main.py | 6 +-
.../tools/stale_dataflow_prebuilt_image_cleaner.sh | 2 +-
CONTRIBUTING.md | 1 +
.../apache/beam/it/gcp/bigquery/BigQueryIOST.java | 6 +-
.../beam/it/gcp/bigquery/BigQueryStreamingLT.java | 11 +-
.../interactive/v1/beam_interactive_api.proto | 13 +
.../beam/model/pipeline/v1/beam_runner_api.proto | 17 +-
runners/google-cloud-dataflow-java/build.gradle | 3 +-
.../dataflow/worker/BatchModeExecutionContext.java | 19 +-
.../worker/StreamingStepMetricsContainer.java | 6 +-
.../worker/StreamingStepMetricsContainerTest.java | 3 +
runners/prism/java/build.gradle | 30 +-
scripts/ci/issue-report/generateReport.js | 2 +-
sdks/go.mod | 10 +-
sdks/go.sum | 20 +-
.../pkg/beam/core/runtime/exec/fullvalue_test.go | 39 +-
.../pkg/beam/runners/prism/internal/engine/data.go | 1 +
.../prism/internal/engine/elementmanager.go | 312 ++++++++++++--
.../runners/prism/internal/engine/engine_test.go | 43 ++
.../beam/runners/prism/internal/engine/strategy.go | 1 +
.../runners/prism/internal/engine/teststream.go | 2 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 50 +++
.../beam/runners/prism/internal/handlecombine.go | 50 ++-
.../runners/prism/internal/handlecombine_test.go | 8 +-
.../prism/internal/jobservices/management.go | 179 ++++++--
.../runners/prism/internal/unimplemented_test.go | 25 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 4 +
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 11 +
sdks/java/io/iceberg/build.gradle | 2 +-
.../python/apache_beam/ml/anomaly}/__init__.py | 0
sdks/python/apache_beam/ml/anomaly/base.py | 211 +++++++++
sdks/python/apache_beam/ml/anomaly/base_test.py | 241 +++++++++++
sdks/python/apache_beam/ml/anomaly/specifiable.py | 326 ++++++++++++++
.../apache_beam/ml/anomaly/specifiable_test.py | 471 +++++++++++++++++++++
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../apache_beam/runners/direct/test_stream_impl.py | 8 +-
.../apache_beam/testing/benchmarks/README.md | 3 +-
.../apache_beam/testing/test_stream_service.py | 6 +-
.../testing/test_stream_service_test.py | 10 +-
.../apache_beam/transforms/periodicsequence.py | 2 +-
.../container/py310/base_image_requirements.txt | 58 +--
.../container/py311/base_image_requirements.txt | 58 +--
.../container/py312/base_image_requirements.txt | 58 +--
.../container/py39/base_image_requirements.txt | 56 +--
.../www/site/content/en/community/contact-us.md | 2 +-
website/www/site/content/en/contribute/_index.md | 1 +
74 files changed, 2105 insertions(+), 379 deletions(-)
copy {examples/notebooks/notebook_test_scripts =>
sdks/python/apache_beam/ml/anomaly}/__init__.py (100%)
create mode 100644 sdks/python/apache_beam/ml/anomaly/base.py
create mode 100644 sdks/python/apache_beam/ml/anomaly/base_test.py
create mode 100644 sdks/python/apache_beam/ml/anomaly/specifiable.py
create mode 100644 sdks/python/apache_beam/ml/anomaly/specifiable_test.py
