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 9aaf9c213e6 Implement java exponential histograms (#28903) (#28995)
add 885f3c9600d Adjust a schedule to run workflows in subgroups (#29049)
add 91207bc65dd Disable comment trigger for Performance and Load Tests
(#29035)
add 8fb23eef6dc [Security] Bump org.json:json due to CVE-2022-45688
(#28962)
add 66c01f03563 Add link to the Dataflow service options page (#29068)
add 12e193370be Arc network update (#29058)
add fec07c11af2 Update base image requirements in preparation for next
release (#29061)
add f0e0c2fc8a9 Fix file paths for test arguments (#29034)
add d25905eb115 Fix Python PreCommit GHA recommendations_ai teardown
(#29067)
add 423ea2360a4 Add InfluxDB credentials (#29071)
add 4f4a58a2325 fix workflows (#29009)
add 95be6b9bd00 [JdbcIO] Add fetchSize to the schema provider for
partitioned reads (#29015)
add 84deb33e38f Add 'release/trigger_all_tests.json' to trigger path of
mass comment PR (#29064)
add 949f12eb809 Bump cloud.google.com/go/profiler from 0.3.1 to 0.4.0 in
/sdks (#29070)
add 68e9c997a90 Move Java Google BOM to best effort post-release task
(#29062)
add 39678b6acd7 Remove command prompts from Go quickstart commands
(#29079)
add 67a39a50df3 make BeamKafkaTable.createKafkaRead to be protected, and
we can override it appending options to KafkaIO.Read (#29051)
add 7632d48c3bd TImeout StreamingDataflowWorkerTest when test stuck
(#29065)
No new revisions were added by this update.
Summary of changes:
.github/build.gradle | 61 ++++++++++++++
.../arc/config/arc_autoscaler.tpl | 2 +-
.../arc/config/arc_deployment.tpl | 3 +
.../arc/environments/beam.env | 12 ++-
.github/gh-actions-self-hosted-runners/arc/gke.tf | 16 +++-
.../arc/kubernetes.tf | 1 +
.../gh-actions-self-hosted-runners/arc/locals.tf | 8 +-
.../gh-actions-self-hosted-runners/arc/network.tf | 10 ++-
.../gh-actions-self-hosted-runners/arc/outputs.tf | 3 +-
.../gh-actions-self-hosted-runners/arc/provider.tf | 6 +-
.../arc/variables.tf | 17 ++++
.github/workflows/README.md | 3 +
.../workflows/beam_CloudML_Benchmarks_Dataflow.yml | 2 +
.../beam_Java_LoadTests_Combine_Smoke.yml | 6 +-
.../beam_LoadTests_Go_CoGBK_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Go_CoGBK_Flink_batch.yml | 4 +-
.../beam_LoadTests_Go_Combine_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Go_Combine_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Go_GBK_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Go_GBK_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Go_ParDo_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Go_ParDo_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Go_SideInput_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Go_SideInput_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Java_CoGBK_Dataflow_Batch.yml | 6 +-
...eam_LoadTests_Java_CoGBK_Dataflow_Streaming.yml | 4 +-
...s_Java_CoGBK_Dataflow_V2_Batch_JavaVersions.yml | 6 +-
...va_CoGBK_Dataflow_V2_Streaming_JavaVersions.yml | 6 +-
...s_Java_CoGBK_SparkStructuredStreaming_Batch.yml | 6 +-
.../beam_LoadTests_Java_Combine_Dataflow_Batch.yml | 4 +-
...m_LoadTests_Java_Combine_Dataflow_Streaming.yml | 4 +-
...Java_Combine_SparkStructuredStreaming_Batch.yml | 4 +-
.../beam_LoadTests_Java_GBK_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Java_GBK_Dataflow_Streaming.yml | 4 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java11.yml | 4 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java17.yml | 4 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java11.yml | 4 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java17.yml | 4 +-
.../workflows/beam_LoadTests_Java_GBK_Smoke.yml | 4 +-
...sts_Java_GBK_SparkStructuredStreaming_Batch.yml | 4 +-
.../beam_LoadTests_Java_ParDo_Dataflow_Batch.yml | 4 +-
...eam_LoadTests_Java_ParDo_Dataflow_Streaming.yml | 4 +-
...s_Java_ParDo_Dataflow_V2_Batch_JavaVersions.yml | 6 +-
...va_ParDo_Dataflow_V2_Streaming_JavaVersions.yml | 6 +-
...s_Java_ParDo_SparkStructuredStreaming_Batch.yml | 4 +-
.../beam_LoadTests_Python_CoGBK_Dataflow_Batch.yml | 14 ++--
...m_LoadTests_Python_CoGBK_Dataflow_Streaming.yml | 6 +-
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 6 +-
...eam_LoadTests_Python_Combine_Dataflow_Batch.yml | 4 +-
...LoadTests_Python_Combine_Dataflow_Streaming.yml | 6 +-
.../beam_LoadTests_Python_Combine_Flink_Batch.yml | 4 +-
...am_LoadTests_Python_Combine_Flink_Streaming.yml | 4 +-
...LoadTests_Python_FnApiRunner_Microbenchmark.yml | 2 +
.../beam_LoadTests_Python_GBK_Dataflow_Batch.yml | 4 +-
...eam_LoadTests_Python_GBK_Dataflow_Streaming.yml | 4 +-
.../beam_LoadTests_Python_GBK_Flink_Batch.yml | 6 +-
...adTests_Python_GBK_reiterate_Dataflow_Batch.yml | 6 +-
...sts_Python_GBK_reiterate_Dataflow_Streaming.yml | 6 +-
.../beam_LoadTests_Python_ParDo_Dataflow_Batch.yml | 6 +-
...m_LoadTests_Python_ParDo_Dataflow_Streaming.yml | 14 ++--
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 12 +--
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 16 ++--
...m_LoadTests_Python_SideInput_Dataflow_Batch.yml | 6 +-
.github/workflows/beam_LoadTests_Python_Smoke.yml | 4 +-
.../workflows/beam_PerformanceTests_AvroIOIT.yml | 4 +-
.../beam_PerformanceTests_AvroIOIT_HDFS.yml | 4 +-
...PerformanceTests_BigQueryIO_Batch_Java_Avro.yml | 4 +-
...PerformanceTests_BigQueryIO_Batch_Java_Json.yml | 4 +-
..._PerformanceTests_BigQueryIO_Streaming_Java.yml | 4 +-
...eam_PerformanceTests_BiqQueryIO_Read_Python.yml | 4 +-
...formanceTests_BiqQueryIO_Write_Python_Batch.yml | 4 +-
.github/workflows/beam_PerformanceTests_Cdap.yml | 4 +-
.../beam_PerformanceTests_Compressed_TextIOIT.yml | 4 +-
...m_PerformanceTests_Compressed_TextIOIT_HDFS.yml | 4 +-
.../beam_PerformanceTests_HadoopFormat.yml | 4 +-
.github/workflows/beam_PerformanceTests_JDBC.yml | 4 +-
.../workflows/beam_PerformanceTests_Kafka_IO.yml | 4 +-
.../beam_PerformanceTests_ManyFiles_TextIOIT.yml | 4 +-
...am_PerformanceTests_ManyFiles_TextIOIT_HDFS.yml | 4 +-
.../beam_PerformanceTests_MongoDBIO_IT.yml | 4 +-
.../beam_PerformanceTests_ParquetIOIT.yml | 4 +-
.../beam_PerformanceTests_ParquetIOIT_HDFS.yml | 4 +-
...erformanceTests_PubsubIOIT_Python_Streaming.yml | 4 +-
...m_PerformanceTests_SQLBigQueryIO_Batch_Java.yml | 4 +-
..._PerformanceTests_SpannerIO_Read_2GB_Python.yml | 4 +-
...manceTests_SpannerIO_Write_2GB_Python_Batch.yml | 4 +-
.../beam_PerformanceTests_SparkReceiver_IO.yml | 4 +-
.../beam_PerformanceTests_TFRecordIOIT.yml | 4 +-
.../beam_PerformanceTests_TFRecordIOIT_HDFS.yml | 4 +-
.../workflows/beam_PerformanceTests_TextIOIT.yml | 4 +-
.../beam_PerformanceTests_TextIOIT_HDFS.yml | 4 +-
.../beam_PerformanceTests_TextIOIT_Python.yml | 4 +-
...PerformanceTests_WordCountIT_PythonVersions.yml | 4 +-
.../workflows/beam_PerformanceTests_XmlIOIT.yml | 4 +-
.../beam_PerformanceTests_XmlIOIT_HDFS.yml | 4 +-
.../beam_PerformanceTests_xlang_KafkaIO_Python.yml | 4 +-
.../beam_PostCommit_BeamMetrics_Publish.yml | 1 -
.github/workflows/beam_PostCommit_Go.yml | 2 +-
.../workflows/beam_PostCommit_Go_Dataflow_ARM.yml | 2 +-
.github/workflows/beam_PostCommit_Go_VR_Flink.yml | 2 +-
.github/workflows/beam_PostCommit_Go_VR_Samza.yml | 2 +-
.github/workflows/beam_PostCommit_Go_VR_Spark.yml | 2 +-
.github/workflows/beam_PostCommit_Java.yml | 2 +-
.../beam_PostCommit_Java_Avro_Versions.yml | 2 +-
.../beam_PostCommit_Java_BigQueryEarlyRollout.yml | 2 +-
.../workflows/beam_PostCommit_Java_DataflowV1.yml | 2 +-
.../workflows/beam_PostCommit_Java_DataflowV2.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow_ARM.yml | 2 +-
...beam_PostCommit_Java_Examples_Dataflow_Java.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow_V2.yml | 2 +-
...m_PostCommit_Java_Examples_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_Java_Examples_Direct.yml | 2 +-
.../beam_PostCommit_Java_Examples_Flink.yml | 2 +-
.../beam_PostCommit_Java_Examples_Spark.yml | 2 +-
.../beam_PostCommit_Java_Hadoop_Versions.yml | 2 +-
.../beam_PostCommit_Java_IO_Performance_Tests.yml | 2 +-
.../beam_PostCommit_Java_InfluxDbIO_IT.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Dataflow_Java11.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Dataflow_Java17.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java11.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java17.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Flink_Java11.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Spark_Java11.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Dataflow.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Dataflow_V2.yml | 2 +-
...am_PostCommit_Java_Nexmark_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Direct.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Flink.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Spark.yml | 2 +-
.../beam_PostCommit_Java_PVR_Flink_Streaming.yml | 2 +-
.../workflows/beam_PostCommit_Java_PVR_Samza.yml | 2 +-
.../beam_PostCommit_Java_PVR_Spark3_Streaming.yml | 2 +-
.../beam_PostCommit_Java_PVR_Spark_Batch.yml | 2 +-
.github/workflows/beam_PostCommit_Java_Sickbay.yml | 2 +-
.../beam_PostCommit_Java_SingleStoreIO_IT.yml | 2 +-
.../beam_PostCommit_Java_Tpcds_Dataflow.yml | 2 +-
.../workflows/beam_PostCommit_Java_Tpcds_Flink.yml | 2 +-
.../workflows/beam_PostCommit_Java_Tpcds_Spark.yml | 2 +-
...am_PostCommit_Java_ValidatesRunner_Dataflow.yml | 2 +-
..._Java_ValidatesRunner_Dataflow_JavaVersions.yml | 10 +--
...mit_Java_ValidatesRunner_Dataflow_Streaming.yml | 2 +-
...PostCommit_Java_ValidatesRunner_Dataflow_V2.yml | 2 +-
..._Java_ValidatesRunner_Dataflow_V2_Streaming.yml | 2 +-
...beam_PostCommit_Java_ValidatesRunner_Direct.yml | 6 +-
...it_Java_ValidatesRunner_Direct_JavaVersions.yml | 10 +--
.../beam_PostCommit_Java_ValidatesRunner_Flink.yml | 3 +-
...ostCommit_Java_ValidatesRunner_Flink_Java11.yml | 11 ++-
.../beam_PostCommit_Java_ValidatesRunner_Samza.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_Spark.yml | 2 +-
...va_ValidatesRunner_SparkStructuredStreaming.yml | 2 +-
...ostCommit_Java_ValidatesRunner_Spark_Java11.yml | 10 +--
...am_PostCommit_Java_ValidatesRunner_Twister2.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_ULR.yml | 6 +-
.github/workflows/beam_PostCommit_Javadoc.yml | 2 +-
.../beam_PostCommit_PortableJar_Flink.yml | 2 +-
.../beam_PostCommit_PortableJar_Spark.yml | 2 +-
.github/workflows/beam_PostCommit_Python.yml | 2 +-
.github/workflows/beam_PostCommit_Python_Arm.yml | 2 +-
.../beam_PostCommit_Python_Examples_Dataflow.yml | 2 +-
.../beam_PostCommit_Python_Examples_Direct.yml | 2 +-
.../beam_PostCommit_Python_Examples_Flink.yml | 4 +-
.../beam_PostCommit_Python_Examples_Spark.yml | 2 +-
.../beam_PostCommit_Python_MongoDBIO_IT.yml | 2 +-
.../beam_PostCommit_Python_Nexmark_Direct.yml | 2 +-
...stCommit_Python_ValidatesContainer_Dataflow.yml | 6 +-
..._Python_ValidatesContainer_Dataflow_With_RC.yml | 6 +-
..._PostCommit_Python_ValidatesRunner_Dataflow.yml | 2 +-
...eam_PostCommit_Python_ValidatesRunner_Flink.yml | 2 +-
...eam_PostCommit_Python_ValidatesRunner_Samza.yml | 2 +-
...eam_PostCommit_Python_ValidatesRunner_Spark.yml | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Direct.yml | 2 +-
.../beam_PostCommit_Python_Xlang_IO_Dataflow.yml | 2 +-
.github/workflows/beam_PostCommit_SQL.yml | 2 +-
.../workflows/beam_PostCommit_Sickbay_Python.yml | 2 +-
.../beam_PostCommit_TransformService_Direct.yml | 2 +-
.../workflows/beam_PostCommit_Website_Publish.yml | 2 +-
.github/workflows/beam_PostCommit_Website_Test.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Direct.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Flink.yml | 2 +-
.../beam_PostCommit_XVR_GoUsingJava_Dataflow.yml | 2 +-
...eam_PostCommit_XVR_JavaUsingPython_Dataflow.yml | 2 +-
..._PostCommit_XVR_PythonUsingJavaSQL_Dataflow.yml | 2 +-
...eam_PostCommit_XVR_PythonUsingJava_Dataflow.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Samza.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Spark3.yml | 2 +-
.../workflows/beam_PreCommit_CommunityMetrics.yml | 4 +-
...am_PreCommit_RAT.yml => beam_PreCommit_GHA.yml} | 49 ++++++-----
.github/workflows/beam_PreCommit_Go.yml | 4 +-
.github/workflows/beam_PreCommit_GoPortable.yml | 4 +-
.github/workflows/beam_PreCommit_GoPrism.yml | 4 +-
.github/workflows/beam_PreCommit_ItFramework.yml | 3 +-
.github/workflows/beam_PreCommit_Java.yml | 3 +-
...eCommit_Java_Amazon-Web-Services2_IO_Direct.yml | 3 +-
...reCommit_Java_Amazon-Web-Services_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Amqp_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Azure_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Cassandra_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Cdap_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Clickhouse_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Csv_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Debezium_IO_Direct.yml | 3 +-
...beam_PreCommit_Java_ElasticSearch_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Examples_Dataflow.yml | 3 +-
...eam_PreCommit_Java_Examples_Dataflow_Java11.yml | 3 +-
...eam_PreCommit_Java_Examples_Dataflow_Java17.yml | 3 +-
...Commit_Java_File-schema-transform_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Flink_Versions.yml | 3 +-
.../beam_PreCommit_Java_GCP_IO_Direct.yml | 3 +-
...> beam_PreCommit_Java_Google-ads_IO_Direct.yml} | 97 +++++++++++-----------
.../beam_PreCommit_Java_HBase_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_HCatalog_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Hadoop_IO_Direct.yml | 3 +-
.../workflows/beam_PreCommit_Java_IOs_Direct.yml | 1 +
.../beam_PreCommit_Java_InfluxDb_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_JDBC_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Jms_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Kafka_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Kinesis_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Kudu_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_MongoDb_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Mqtt_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Neo4j_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_PVR_Flink_Batch.yml | 3 +-
.../beam_PreCommit_Java_PVR_Flink_Docker.yml | 3 +-
.../beam_PreCommit_Java_Parquet_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Pulsar_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_RabbitMq_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Redis_IO_Direct.yml | 3 +-
...m_PreCommit_Java_RequestResponse_IO_Direct.yml} | 97 +++++++++++-----------
.../beam_PreCommit_Java_SingleStore_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Snowflake_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Solr_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Spark3_Versions.yml | 3 +-
.../beam_PreCommit_Java_Splunk_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Thrift_IO_Direct.yml | 3 +-
.../beam_PreCommit_Java_Tika_IO_Direct.yml | 3 +-
.../workflows/beam_PreCommit_Kotlin_Examples.yml | 3 +-
.../workflows/beam_PreCommit_Portable_Python.yml | 3 +-
.github/workflows/beam_PreCommit_Python.yml | 4 +-
.github/workflows/beam_PreCommit_PythonDocker.yml | 4 +-
.github/workflows/beam_PreCommit_PythonDocs.yml | 4 +-
.../workflows/beam_PreCommit_PythonFormatter.yml | 4 +-
.github/workflows/beam_PreCommit_PythonLint.yml | 4 +-
.../workflows/beam_PreCommit_Python_Coverage.yml | 4 +-
.../workflows/beam_PreCommit_Python_Dataframes.yml | 4 +-
.../workflows/beam_PreCommit_Python_Examples.yml | 4 +-
.../beam_PreCommit_Python_Integration.yml | 4 +-
.../workflows/beam_PreCommit_Python_PVR_Flink.yml | 3 +-
.../workflows/beam_PreCommit_Python_Runners.yml | 4 +-
.../workflows/beam_PreCommit_Python_Transforms.yml | 4 +-
.github/workflows/beam_PreCommit_RAT.yml | 2 +-
.github/workflows/beam_PreCommit_SQL.yml | 4 +-
.github/workflows/beam_PreCommit_SQL_Java11.yml | 4 +-
.github/workflows/beam_PreCommit_SQL_Java17.yml | 4 +-
.github/workflows/beam_PreCommit_Spotless.yml | 3 +-
.github/workflows/beam_PreCommit_Typescript.yml | 4 +-
.github/workflows/beam_PreCommit_Website.yml | 4 +-
.../workflows/beam_PreCommit_Website_Stage_GCS.yml | 4 +-
.github/workflows/beam_PreCommit_Whitespace.yml | 4 +-
...hon_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt | 0
...python_CoGBK_Dataflow_Batch_100b_Single_Key.txt | 0
.../python_CoGBK_Dataflow_Batch_10kB.txt | 0
.../python_CoGBK_Dataflow_Batch_2MB.txt | 0
...GBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt | 0
..._CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt | 0
.../python_CoGBK_Dataflow_Flink_Batch_10kB.txt | 0
...CoGBK_Dataflow_Streaming_100b_Multiple_Keys.txt | 0
...on_CoGBK_Dataflow_Streaming_100b_Single_Key.txt | 0
.../python_CoGBK_Dataflow_Streaming_10kB.txt | 0
.../python_CoGBK_Dataflow_Streaming_2MB.txt | 0
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
contributor-docs/release-guide.md | 52 +++++++++---
release/src/main/scripts/mass_comment.py | 21 +----
release/src/main/scripts/verify_release_build.sh | 8 +-
.../dataflow/options/DataflowPipelineOptions.java | 5 +-
.../worker/StreamingDataflowWorkerTest.java | 2 +
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
.../apache/beam/sdk/schemas/utils/JsonUtils.java | 2 +-
.../sql/meta/provider/kafka/BeamKafkaTable.java | 2 +-
.../sql/meta/provider/kafka/KafkaTestTable.java | 2 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 6 ++
.../beam/sdk/io/jdbc/JdbcSchemaIOProvider.java | 6 ++
.../ml/gcp/recommendations_ai_test_it.py | 8 ++
.../container/py310/base_image_requirements.txt | 54 ++++++------
.../container/py311/base_image_requirements.txt | 52 ++++++------
.../container/py38/base_image_requirements.txt | 54 ++++++------
.../container/py39/base_image_requirements.txt | 56 +++++++------
settings.gradle.kts | 2 +
.../site/content/en/get-started/quickstart-go.md | 12 +--
292 files changed, 969 insertions(+), 643 deletions(-)
create mode 100644 .github/build.gradle
copy .github/workflows/{beam_PreCommit_RAT.yml => beam_PreCommit_GHA.yml} (70%)
copy .github/workflows/{beam_PreCommit_Java_Mqtt_IO_Direct.yml =>
beam_PreCommit_Java_Google-ads_IO_Direct.yml} (54%)
copy .github/workflows/{beam_PreCommit_Java_Kudu_IO_Direct.yml =>
beam_PreCommit_Java_RequestResponse_IO_Direct.yml} (54%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Batch_100b_Single_Key.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Batch_10kB.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Batch_2MB.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Flink_Batch_10kB.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Streaming_100b_Multiple_Keys.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Streaming_100b_Single_Key.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Streaming_10kB.txt (100%)
rename .github/workflows/load-tests-job-configs/{python-cogbk =>
}/python_CoGBK_Dataflow_Streaming_2MB.txt (100%)
