This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 6e03cfd (commit)
to dcf3e78 (commit)
from 6e03cfd Merge pull request #13952 from [BEAM-11377] Disable mvn http
keepalive.
add 88190dc Removes VR test
add 7502992 Merge pull request #13957: [BEAM-11787] Removes new VR test
that fails for Dataflow
add 3f76b5e [BEAM-11787] Do not call `translations.optimize_pipeline` in
Dataflow Streaming (#13951)
add e0ba4dc update versions
add 5136c4e update autovalue version
add a5750ab Merge pull request #13765: [BEAM-11648] In preparation for
new BigQuery sink, update GCP BOM
add 625ee1f [BEAM-2914] Add portable merging window support to Python.
(#12995)
add e26fe06 [BEAM-11791] Continuously running microbenchmark for
FnApiRunner
add ee4cf67 Merge pull request #13906 from pabloem/fnrunner-ubench
add 97a4a19 [BEAM-11647] Fix go:goBuild gradle rules for build collision
(#13958)
add 5880bf1 Fixes a checkstyle error in UdfTestProvider
add 7e18e71 Merge pull request #13959: [BEAM-11794] Fixes a checkstyle
error in UdfTestProvider
add 8f219a2 [BEAM-11611] Add transformation for computing approximate
quantiles. (#13889)
add 04eff7d Integrate BigQuery sink file loads with GroupIntoBatches
add dc29b8c Merge pull request #13859 from [BEAM-11772] Integrate
BigQuery sink file loads with GroupIntoBatches
add e95c5dd [BEAM-10925] Don't publish udf-test-provider to Maven.
add b2c79ad Merge pull request #13967 from ibzib/dont-publish-test
add adf4555 [BEAM-11780] Use vendored cloudbuild python client. (#13933)
add dcf3e78 [BEAM-11804] Remove vendors/sdk-java-extensions-protobuf
(#13968)
No new revisions were added by this update.
Summary of changes:
.../job_LoadTests_FnApiRunner_Python.groovy | 64 +
...ks.json => Python_FnApiRunner_ubenchmarks.json} | 129 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 16 +-
runners/flink/flink_runner.gradle | 1 -
.../streaming/ExecutableStageDoFnOperator.java | 2 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
runners/java-fn-execution/build.gradle | 1 -
.../control/ProcessBundleDescriptors.java | 2 +-
.../fnexecution/state/StateRequestHandlers.java | 2 +-
.../runners/fnexecution/wire}/ByteStringCoder.java | 11 +-
.../fnexecution/wire}/ByteStringCoderTest.java | 4 +-
sdks/go/build.gradle | 5 +-
sdks/go/pkg/beam/transforms/stats/quantiles.go | 711 ++++++++
.../go/pkg/beam/transforms/stats/quantiles_test.go | 275 +++
sdks/go/test/run_integration_tests.sh | 2 +-
.../container/license_scripts/dep_urls_java.yaml | 2 +-
.../extensions/sql/udf-test-provider/build.gradle | 7 +-
.../extensions/sql/provider/UdfTestProvider.java | 2 +-
sdks/java/io/google-cloud-platform/build.gradle | 3 +-
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 130 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 17 +-
.../gcp/bigquery/WriteGroupedRecordsToFiles.java | 21 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 10 +
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 69 +
.../runners/dataflow/dataflow_runner.py | 58 +-
.../internal/clients/cloudbuild}/__init__.py | 10 +-
.../clients/cloudbuild/cloudbuild_v1_client.py | 686 +++++++
.../clients/cloudbuild/cloudbuild_v1_messages.py | 1911 ++++++++++++++++++++
.../runners/portability/flink_runner_test.py | 3 +
.../runners/portability/fn_api_runner/execution.py | 241 ++-
.../portability/fn_api_runner/fn_runner_test.py | 37 +
.../portability/fn_api_runner/translations_test.py | 1 -
.../runners/portability/sdk_container_builder.py | 58 +-
.../runners/portability/spark_runner_test.py | 3 +
.../apache_beam/runners/worker/bundle_processor.py | 43 +
.../apache_beam/testing/load_tests/load_test.py | 3 +-
.../testing/load_tests/load_test_metrics_utils.py | 24 +-
.../testing/load_tests/microbenchmarks_test.py | 85 +
.../tools/fn_api_runner_microbenchmark.py | 7 +-
sdks/python/setup.py | 2 -
settings.gradle.kts | 1 -
vendor/sdks-java-extensions-protobuf/build.gradle | 62 -
42 files changed, 4386 insertions(+), 337 deletions(-)
create mode 100644 .test-infra/jenkins/job_LoadTests_FnApiRunner_Python.groovy
copy
.test-infra/metrics/grafana/dashboards/perftests_metrics/{Python_WordCount_IT_Benchmarks.json
=> Python_FnApiRunner_ubenchmarks.json} (52%)
copy
{sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf
=>
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire}/ByteStringCoder.java
(91%)
copy
{sdks/java/extensions/protobuf/src/test/java/org/apache/beam/sdk/extensions/protobuf
=>
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/wire}/ByteStringCoderTest.java
(97%)
create mode 100644 sdks/go/pkg/beam/transforms/stats/quantiles.go
create mode 100644 sdks/go/pkg/beam/transforms/stats/quantiles_test.go
copy sdks/python/apache_beam/{io/gcp/internal/clients/bigquery =>
runners/dataflow/internal/clients/cloudbuild}/__init__.py (77%)
create mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_client.py
create mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_messages.py
create mode 100644
sdks/python/apache_beam/testing/load_tests/microbenchmarks_test.py
delete mode 100644 vendor/sdks-java-extensions-protobuf/build.gradle
