This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 17f7a5d1aff make incoming message public (#25803)
add e235761ba52 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#25816)
add 038e490c35a Bump grpcio from 1.49.1 to 1.51.3 in /sdks/python (#25814)
add 917921fa177 [Go SDK] Fix most compile and bugs on Windows. (#25634)
add 509052c0488 Mark that 2.46 has been released now that the release is
finalized (#25818)
add 0d515df6520 Infrastructure-as-Code to provision a private GKE
autopilot kubernetes cluster and strimzi kafka (#25686)
add 8b3f2964344 Remove save main session option in pubsubio_perf_test
(#25822)
add 5de5ce8f30e LOG error for illegal ramBytes (#25763)
add 3de1eb18345 [25705] Refactor BigQuery SchemaTransforms naming (#25706)
add 366495683eb updated error message
add 1c8d85c048c linting
add afce68d95c0 Merge pull request #25826: Corrected
GscUtil.RewriteOp.OnFailure() error message
add 04c2de61e5d Fix OutputSampler's coder. (#25805)
add daaaaafc0e0 [BEAM-14307] Re-Fix Slow Side input pattern bug in sample
add 4189320e49e Merge pull request #25829: [BEAM-14307] Re-Fix Slow Side
input pattern bug in sample
add 81517a7fffd Add support for common collections.abc types (#25798)
add 6b18305a625 Improve stage packages race condition by checking if
already staged before each try (#25827)
add 6270ec9d014 Bump wazero to v1.0.0-rc.1 (#25691)
add 20510623041 Re-enable Storage Write API tests for Runner v2
add 6f0dfae90be Merge pull request #21814: Re-enable Storage Write API
tests for Runner v2
add 8eefbd4e2b5 Drop myself from Java reviewers
add 77d03e952c7 Merge pull request #25800: Drop myself from Java reviewers
No new revisions were added by this update.
Summary of changes:
.github/REVIEWERS.yml | 1 -
.test-infra/kafka/README.md | 36 +
.../kafka/strimzi/01-strimzi-operator/README.md | 28 +
.../strimzi/01-strimzi-operator/kustomization.yaml | 23 +
.../strimzi/01-strimzi-operator/namespace.yaml | 22 +
...10-ServiceAccount-strimzi-cluster-operator.yaml | 23 +
...-ClusterRole-strimzi-cluster-operator-role.yaml | 170 +
.../020-RoleBinding-strimzi-cluster-operator.yaml | 31 +
...-ClusterRole-strimzi-cluster-operator-role.yaml | 55 +
...lusterRoleBinding-strimzi-cluster-operator.yaml | 31 +
...-ClusterRole-strimzi-cluster-operator-role.yaml | 48 +
.../022-RoleBinding-strimzi-cluster-operator.yaml | 31 +
...-ClusterRole-strimzi-cluster-operator-role.yaml | 82 +
.../023-RoleBinding-strimzi-cluster-operator.yaml | 31 +
.../030-ClusterRole-strimzi-kafka-broker.yaml | 32 +
...i-cluster-operator-kafka-broker-delegation.yaml | 33 +
.../031-ClusterRole-strimzi-entity-operator.yaml | 61 +
...luster-operator-entity-operator-delegation.yaml | 33 +
.../033-ClusterRole-strimzi-kafka-client.yaml | 33 +
...i-cluster-operator-kafka-client-delegation.yaml | 34 +
.../01-strimzi-operator/v0.33.2/040-Crd-kafka.yaml | 6208 ++++++++++++++++++++
.../v0.33.2/041-Crd-kafkaconnect.yaml | 1952 ++++++
.../v0.33.2/042-Crd-strimzipodset.yaml | 135 +
.../v0.33.2/043-Crd-kafkatopic.yaml | 270 +
.../v0.33.2/044-Crd-kafkauser.yaml | 702 +++
.../v0.33.2/045-Crd-kafkamirrormaker.yaml | 1228 ++++
.../v0.33.2/046-Crd-kafkabridge.yaml | 1178 ++++
.../v0.33.2/047-Crd-kafkaconnector.yaml | 146 +
.../v0.33.2/048-Crd-kafkamirrormaker2.yaml | 1992 +++++++
.../v0.33.2/049-Crd-kafkarebalance.yaml | 159 +
.../050-ConfigMap-strimzi-cluster-operator.yaml | 52 +
.../060-Deployment-strimzi-cluster-operator.yaml | 155 +
.../01-strimzi-operator/v0.33.2/kustomization.yaml | 46 +
.../kafka/strimzi/02-kafka-persistent/README.md | 28 +
.../base/v0.33.2/kafka-persistent.yaml | 53 +
.../base/v0.33.2/kustomization.yaml | 22 +
.../gke-internal-load-balanced/kustomization.yaml | 26 +
.../gke-internal-load-balanced/listeners.yaml | 52 +
.test-infra/kafka/strimzi/README.md | 160 +
.test-infra/terraform/OWNERS | 5 +
.test-infra/terraform/README.md | 31 +
.../terraform/google-cloud-platform/README.md | 44 +
.../google-kubernetes-engine/README.md | 56 +
.../google-kubernetes-engine/main.tf | 73 +
.../modules/01-setup/README.md | 26 +
.../modules/01-setup/iam.tf | 39 +
.../modules/01-setup/output.tf | 22 +
.../modules/01-setup/provider.tf | 22 +
.../modules/01-setup/services.tf | 28 +
.../modules/01-setup/variables.tf | 32 +
.../modules/02-network/README.md | 26 +
.../modules/02-network/nat.tf | 43 +
.../modules/02-network/network.tf | 65 +
.../modules/02-network/output.tf | 37 +
.../modules/02-network/provider.tf | 22 +
.../modules/02-network/services.tf | 23 +
.../modules/02-network/variables.tf | 44 +
.../modules/03-cluster/README.md | 22 +
.../modules/03-cluster/cluster.tf | 42 +
.../modules/03-cluster/provider.tf | 22 +
.../modules/03-cluster/services.tf | 23 +
.../modules/03-cluster/variables.tf | 53 +
.../modules/04-bastion/README.md | 22 +
.../modules/04-bastion/compute.tf | 64 +
.../modules/04-bastion/data.tf | 44 +
.../modules/04-bastion/provider.tf | 22 +
.../modules/04-bastion/services.tf | 23 +
.../modules/04-bastion/tinyproxy.conf | 368 ++
.../modules/04-bastion/variables.tf | 67 +
.../google-kubernetes-engine/variables.tf | 42 +
.../google-kubernetes-engine/versions.tf | 32 +
CHANGES.md | 2 +-
.../apache/beam/examples/snippets/Snippets.java | 4 +-
runners/google-cloud-dataflow-java/build.gradle | 1 -
.../beam/runners/dataflow/util/PackageUtil.java | 10 +-
.../runners/dataflow/util/PackageUtilTest.java | 10 +-
sdks/go.mod | 22 +-
sdks/go.sum | 33 +-
sdks/go/examples/wasm/README.md | 6 +-
.../runtime/xlangx/expansionx/download_test.go | 2 +-
sdks/go/pkg/beam/core/util/symtab/symtab_test.go | 3 +
sdks/go/pkg/beam/io/filesystem/local/local_test.go | 5 +-
sdks/go/pkg/beam/io/filesystem/memfs/memory.go | 7 +-
.../go/pkg/beam/io/filesystem/memfs/memory_test.go | 11 +-
sdks/go/pkg/beam/io/filesystem/util.go | 12 +
.../test/integration/internal/jars/run_nonunix.go | 3 +-
.../transforms/resourcehints/ResourceHints.java | 25 +-
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 4 +-
.../harness/data/PCollectionConsumerRegistry.java | 38 +-
.../beam/fn/harness/debug/OutputSampler.java | 39 +-
.../beam/fn/harness/debug/DataSamplerTest.java | 31 +-
.../beam/fn/harness/debug/OutputSamplerTest.java | 49 +-
...eryExportReadSchemaTransformConfiguration.java} | 18 +-
...BigQueryExportReadSchemaTransformProvider.java} | 36 +-
...ileLoadsWriteSchemaTransformConfiguration.java} | 18 +-
...ueryFileLoadsWriteSchemaTransformProvider.java} | 32 +-
...ueryExportReadSchemaTransformProviderTest.java} | 49 +-
...FileLoadsWriteSchemaTransformProviderTest.java} | 50 +-
.../apache_beam/io/gcp/pubsub_io_perf_test.py | 3 -
.../typehints/native_type_compatibility.py | 23 +
.../typehints/native_type_compatibility_test.py | 29 +
sdks/python/build-requirements.txt | 2 +-
102 files changed, 17267 insertions(+), 196 deletions(-)
create mode 100644 .test-infra/kafka/README.md
create mode 100644 .test-infra/kafka/strimzi/01-strimzi-operator/README.md
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/kustomization.yaml
create mode 100644 .test-infra/kafka/strimzi/01-strimzi-operator/namespace.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/010-ServiceAccount-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/020-ClusterRole-strimzi-cluster-operator-role.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/020-RoleBinding-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/021-ClusterRole-strimzi-cluster-operator-role.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/021-ClusterRoleBinding-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/022-ClusterRole-strimzi-cluster-operator-role.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/022-RoleBinding-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/023-ClusterRole-strimzi-cluster-operator-role.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/023-RoleBinding-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/030-ClusterRole-strimzi-kafka-broker.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/030-ClusterRoleBinding-strimzi-cluster-operator-kafka-broker-delegation.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/031-ClusterRole-strimzi-entity-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/033-ClusterRole-strimzi-kafka-client.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/033-ClusterRoleBinding-strimzi-cluster-operator-kafka-client-delegation.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/040-Crd-kafka.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/041-Crd-kafkaconnect.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/042-Crd-strimzipodset.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/043-Crd-kafkatopic.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/044-Crd-kafkauser.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/045-Crd-kafkamirrormaker.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/046-Crd-kafkabridge.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/047-Crd-kafkaconnector.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/048-Crd-kafkamirrormaker2.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/049-Crd-kafkarebalance.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/050-ConfigMap-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/060-Deployment-strimzi-cluster-operator.yaml
create mode 100644
.test-infra/kafka/strimzi/01-strimzi-operator/v0.33.2/kustomization.yaml
create mode 100644 .test-infra/kafka/strimzi/02-kafka-persistent/README.md
create mode 100644
.test-infra/kafka/strimzi/02-kafka-persistent/base/v0.33.2/kafka-persistent.yaml
create mode 100644
.test-infra/kafka/strimzi/02-kafka-persistent/base/v0.33.2/kustomization.yaml
create mode 100644
.test-infra/kafka/strimzi/02-kafka-persistent/overlays/gke-internal-load-balanced/kustomization.yaml
create mode 100644
.test-infra/kafka/strimzi/02-kafka-persistent/overlays/gke-internal-load-balanced/listeners.yaml
create mode 100644 .test-infra/kafka/strimzi/README.md
create mode 100644 .test-infra/terraform/OWNERS
create mode 100644 .test-infra/terraform/README.md
create mode 100644 .test-infra/terraform/google-cloud-platform/README.md
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/README.md
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/main.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/01-setup/README.md
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/01-setup/iam.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/01-setup/output.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/01-setup/provider.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/01-setup/services.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/01-setup/variables.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/README.md
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/nat.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/network.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/output.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/provider.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/services.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/02-network/variables.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/03-cluster/README.md
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/03-cluster/cluster.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/03-cluster/provider.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/03-cluster/services.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/03-cluster/variables.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/README.md
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/compute.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/data.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/provider.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/services.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/tinyproxy.conf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/modules/04-bastion/variables.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/variables.tf
create mode 100644
.test-infra/terraform/google-cloud-platform/google-kubernetes-engine/versions.tf
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQuerySchemaTransformReadConfiguration.java
=> BigQueryExportReadSchemaTransformConfiguration.java} (80%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQuerySchemaTransformReadProvider.java
=> BigQueryExportReadSchemaTransformProvider.java} (81%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQuerySchemaTransformWriteConfiguration.java
=> BigQueryFileLoadsWriteSchemaTransformConfiguration.java} (77%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQuerySchemaTransformWriteProvider.java
=> BigQueryFileLoadsWriteSchemaTransformProvider.java} (88%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQuerySchemaTransformReadProviderTest.java
=> BigQueryExportReadSchemaTransformProviderTest.java} (82%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQuerySchemaTransformWriteProviderTest.java
=> BigQueryFileLoadsWriteSchemaTransformProviderTest.java} (85%)
