This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from b3a62ee97c7 Upgrade expansion jar to java17 (#38931)
add 6ed0635429a Spanner: Extend SpannerIO to support Spanner Omni mTLS
setup (#38928)
add 378e10de4ea ClickHouseIO: Add DateTime64 support for sub-second
timestamp precision (#38510)
add 98e29d99fcd Revert "Upgrade expansion jar to java17 (#38931)" (#38965)
add bde545f91e4 Add support for STDDEV_POP and STDDEV_SAMP in VarianceFn
(#38871)
add 77348121ee9 Update BEAM_DEV_SDK_CONTAINER_TAG version (#38963)
add a996a9fb610 Bump protobufjs from 8.4.0 to 8.6.0 in /sdks/typescript
(#38968)
add 2c4822959e1 Bump form-data from 2.5.5 to 2.5.6 in /sdks/typescript
(#38967)
add b7bc937f592 Use Flink 2.0 for load tests (#38279)
No new revisions were added by this update.
Summary of changes:
.../actions/setup-environment-action/action.yml | 2 +-
.../beam_LoadTests_Go_CoGBK_Flink_batch.yml | 4 +-
.../beam_LoadTests_Go_Combine_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Go_GBK_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Go_ParDo_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Go_SideInput_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Python_Combine_Flink_Batch.yml | 4 +-
...am_LoadTests_Python_Combine_Flink_Streaming.yml | 4 +-
.../beam_LoadTests_Python_GBK_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 4 +-
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 4 +-
.../workflows/beam_PreCommit_Flink_Container.yml | 4 +-
.../beam_PreCommit_Xlang_Generated_Transforms.yml | 2 +-
.../workflows/beam_Publish_Docker_Snapshots.yml | 4 +-
.test-infra/dataproc/flink_cluster.sh | 6 +-
CHANGES.md | 1 +
sdks/java/expansion-service/container/Dockerfile | 2 +-
.../impl/transform/BeamBuiltinAggregations.java | 2 +
.../sql/impl/transform/agg/VarianceFn.java | 38 ++++-
.../sql/BeamSqlDslAggregationVarianceTest.java | 43 +++++-
.../sql/impl/transform/agg/VarianceFnTest.java | 25 ++-
.../beam/sdk/io/clickhouse/ClickHouseIO.java | 3 +
.../beam/sdk/io/clickhouse/ClickHouseWriter.java | 40 +++++
.../apache/beam/sdk/io/clickhouse/TableSchema.java | 53 ++++++-
.../clickhouse/src/main/javacc/ColumnTypeParser.jj | 27 ++++
.../beam/sdk/io/clickhouse/ClickHouseIOIT.java | 119 ++++++++++++++
.../sdk/io/clickhouse/ClickHouseWriterTest.java | 141 +++++++++++++++++
.../beam/sdk/io/clickhouse/TableSchemaTest.java | 102 ++++++++++++
sdks/java/io/expansion-service/build.gradle | 4 +-
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 13 +-
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 37 +++++
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 171 ++++++++++++++++++++-
.../io/gcp/spanner/SpannerTransformRegistrar.java | 30 ++++
.../MetadataSpannerConfigFactory.java | 6 +
.../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 33 ++--
.../beam/sdk/io/gcp/spanner/SpannerTestHelper.java | 110 +++++++++++++
.../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 110 +++++++------
.../changestreams/it/IntegrationTestEnv.java | 17 +-
.../changestreams/it/SpannerChangeStreamIT.java | 19 ++-
...StreamOrderedByTimestampAndTransactionIdIT.java | 10 +-
...nnerChangeStreamOrderedWithinKeyGloballyIT.java | 10 +-
.../it/SpannerChangeStreamOrderedWithinKeyIT.java | 10 +-
.../it/SpannerChangeStreamPlacementTableIT.java | 19 ++-
...pannerChangeStreamPlacementTablePostgresIT.java | 10 +-
.../it/SpannerChangeStreamPostgresIT.java | 10 +-
...SpannerChangeStreamTransactionBoundariesIT.java | 10 +-
.../it/SpannerChangeStreamsSchemaTransformIT.java | 4 +
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
sdks/typescript/package-lock.json | 43 +++---
sdks/typescript/package.json | 2 +-
51 files changed, 1151 insertions(+), 187 deletions(-)
create mode 100644
sdks/java/io/clickhouse/src/test/java/org/apache/beam/sdk/io/clickhouse/ClickHouseWriterTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTestHelper.java
