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 b31a7ea (commit)
to 9876fe4 (commit)
from b31a7ea Merge pull request #15547 from ibzib/BEAM-12898
add 42247e9 [BEAM-12383] Adding Go SDK and Kafka IO to Gradle
cross-language test suites. (#15094)
add e28ed48 Implicitly watch and track anonymous pipeline and PCollections
add 1563588 Merge pull request #15551 from KevinGG/anonymous
add 55e028e Reject requests when parameter names cannot be validated
unless explicitly requested via the 'ignore' pattern
add a6652ce Updates error message
add 9431cf5 Merge pull request #15557: [BEAM-12769] Reject requests when
parameter names cannot be validated
add 9d86925 Fix some website logos.
add 299b5e5 Merge pull request #15533 from robertwb/logos
add 685368d Avoid setting empty builders in proto setters
add ee4c85a Merge pull request #15488 from paulferaud/patch-1
add 0efc4f3 [BEAM-10822] Fixed typo in BigqueryClient
add 11aa4a0 Merge pull request #15559 from [BEAM-10822] Fixed typo in
BigqueryClient
add af81f06 [BEAM-12869] Bump tensorflow from 2.5.0 to 2.5.1 in
/sdks/python/container (#15428)
add 1eda7fc [BEAM-12946] Fix SmallestPerKey, add unit testing (#15567)
add b66e4b1 Run BigQuery queries with batch priority
add 436fa06 Allow changing query priority in ReadFromBigQuery
add 59b0fb9 Update CHANGES
add 84c082d Merge pull request #15536 from [BEAM-12913] Enable
configuration of query priority in ReadFromBigQuery
add 7dabfc1 Add back 'more' break
add e4f6037 Merge pull request #15526 from Minor: Add back 'more' break
in Beam 2.32.0 blog post
add 9d06c6a [BEAM-12908] Sickbay pubsublite.ReadWriteIT
add dc58a62 Merge pull request #15571 from y1chi/BEAM-12908
add 6c081a9 Relocate Go SDK breaking change note out of template into
2.33.0. (#15574)
add 37bca02 [BEAM-12898] Minor fix to Kubernetes.groovy postBuildScript.
add 9876fe4 Merge pull request #15565 from y1chi/beam-12898-fix
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/Kubernetes.groovy | 8 +-
CHANGES.md | 19 ++---
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 22 +++++-
.../core/construction/TriggerTranslation.java | 2 +-
runners/flink/job-server/flink_job_server.gradle | 7 +-
runners/google-cloud-dataflow-java/build.gradle | 11 ++-
runners/samza/job-server/build.gradle | 7 +-
runners/spark/job-server/spark_job_server.gradle | 7 +-
sdks/go/pkg/beam/transforms/top/top.go | 2 +-
sdks/go/pkg/beam/transforms/top/top_test.go | 86 +++++++++++++++++++++
sdks/go/test/build.gradle | 36 +++++++++
sdks/go/test/integration/flags.go | 6 ++
sdks/go/test/integration/integration.go | 7 ++
.../io/xlang/kafka/{jar.go => cluster.go} | 48 +++---------
.../io/xlang/kafka/{jar.go => cluster_unix.go} | 50 ++++--------
sdks/go/test/integration/io/xlang/kafka/jar.go | 33 +++++---
sdks/go/test/integration/io/xlang/kafka/kafka.go | 50 +++++++-----
.../test/integration/io/xlang/kafka/kafka_test.go | 31 ++++++--
sdks/go/test/run_validatesrunner_tests.sh | 2 +-
.../service/JavaClassLookupTransformProvider.java | 30 ++++---
.../JavaClassLookupTransformProviderTest.java | 4 +-
.../beam/sdk/io/gcp/testing/BigqueryClient.java | 6 +-
.../BigQueryTimePartitioningClusteringIT.java | 4 +-
.../beam/sdk/io/gcp/pubsublite/ReadWriteIT.java | 2 +
.../sdk/io/gcp/testing/BigqueryClientTest.java | 2 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 19 ++++-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 11 ++-
.../apache_beam/io/gcp/bigquery_tools_test.py | 33 ++++++++
.../runners/interactive/interactive_beam.py | 13 +++-
.../runners/interactive/interactive_beam_test.py | 1 -
.../runners/interactive/interactive_environment.py | 14 ++--
sdks/python/container/base_image_requirements.txt | 2 +-
sdks/python/test-suites/direct/xlang/build.gradle | 7 +-
website/www/site/content/en/blog/beam-2.32.0.md | 5 +-
.../content/en/powered-by/commercial/dataflow.md | 2 +-
.../site/content/en/powered-by/open-source/scio.md | 1 +
.../site/content/en/powered-by/open-source/tfx.md | 2 +-
.../site/static/images/logos/powered-by/tfx.png | Bin 0 -> 14227 bytes
38 files changed, 424 insertions(+), 168 deletions(-)
copy sdks/go/test/integration/io/xlang/kafka/{jar.go => cluster.go} (52%)
copy sdks/go/test/integration/io/xlang/kafka/{jar.go => cluster_unix.go} (52%)
create mode 100644 website/www/site/static/images/logos/powered-by/tfx.png
