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 7632d48c3bd TImeout StreamingDataflowWorkerTest when test stuck
(#29065)
add c6ab5fe272f Refactor StateFetcher (#28755)
add 641b95df45d Bump google.golang.org/api from 0.147.0 to 0.148.0 in
/sdks (#29086)
add 7610d46f745 Remove warning in dataframes io. (#29084)
add 0a11c04ee1d beam_performance_singlestoreio (#28986)
add e7a6405800a Setup Java 21 container (#28918)
add 6b927423f02 Editorial pass on content (#29094)
add b85c40bbdc8 Fix rrio PreCommit build configs (#29097)
add 1284d769892 Fix various issues in SplunkIO (#28825)
add fd1b87849c0 Refactor prepare arguments step for Github actions (#29090)
add 96acc2cdd5d [YAML] Improved pipeline schema definition. (#29083)
add 97a52af980d [yaml] support gcs location for main.py yaml input file
(#29014)
add abce1ad34eb Merge pull request #29093 [YAML] Don't require redundant
input for YamlTransform.
add 18852513309 Add jsonschema dependency.
add b402fafd44f Validate incoming JSON data from pubsub.
add 2e676a369ad Regenrate python base deps files.
add 142bcddf91b Merge branch 'master' into yaml-json-validate
add b97c7dee5aa yapf
add 879935e88d1 Merge pull request #29080 Validate incoming JSON data from
pubsub.
add ffd44b446c4 Add workflows to README (#29096)
add 7bd25a8e6d1 Bump cloud.google.com/go/spanner from 1.50.0 to 1.51.0 in
/sdks (#29046)
add 84c9ea0a48b Bump golang.org/x/net from 0.7.0 to 0.17.0 in
/learning/katas/go (#28947)
add 68fec9e1ac6 Include ID and name of tracked thread in lull message
(#29007)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 172 ++++++++----
.../workflows/beam_CloudML_Benchmarks_Dataflow.yml | 2 +-
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 10 +-
.../beam_Java_LoadTests_Combine_Smoke.yml | 6 +-
.../beam_LoadTests_Go_CoGBK_Dataflow_Batch.yml | 8 +-
.../beam_LoadTests_Go_CoGBK_Flink_batch.yml | 6 +-
.../beam_LoadTests_Go_Combine_Dataflow_Batch.yml | 31 ++-
.../beam_LoadTests_Go_Combine_Flink_Batch.yml | 6 +-
.../beam_LoadTests_Go_GBK_Dataflow_Batch.yml | 14 +-
.../beam_LoadTests_Go_GBK_Flink_Batch.yml | 12 +-
.../beam_LoadTests_Go_ParDo_Dataflow_Batch.yml | 8 +-
.../beam_LoadTests_Go_ParDo_Flink_Batch.yml | 8 +-
.../beam_LoadTests_Go_SideInput_Dataflow_Batch.yml | 4 +-
.../beam_LoadTests_Go_SideInput_Flink_Batch.yml | 4 +-
.../beam_LoadTests_Java_CoGBK_Dataflow_Batch.yml | 8 +-
...eam_LoadTests_Java_CoGBK_Dataflow_Streaming.yml | 33 ++-
...s_Java_CoGBK_Dataflow_V2_Batch_JavaVersions.yml | 16 +-
...va_CoGBK_Dataflow_V2_Streaming_JavaVersions.yml | 16 +-
...s_Java_CoGBK_SparkStructuredStreaming_Batch.yml | 8 +-
.../beam_LoadTests_Java_Combine_Dataflow_Batch.yml | 6 +-
...m_LoadTests_Java_Combine_Dataflow_Streaming.yml | 10 +-
...Java_Combine_SparkStructuredStreaming_Batch.yml | 10 +-
.../beam_LoadTests_Java_GBK_Dataflow_Batch.yml | 14 +-
.../beam_LoadTests_Java_GBK_Dataflow_Streaming.yml | 14 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java11.yml | 28 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java17.yml | 28 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java11.yml | 28 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java17.yml | 28 +-
.../workflows/beam_LoadTests_Java_GBK_Smoke.yml | 8 +-
...sts_Java_GBK_SparkStructuredStreaming_Batch.yml | 14 +-
.../beam_LoadTests_Java_ParDo_Dataflow_Batch.yml | 13 +-
...eam_LoadTests_Java_ParDo_Dataflow_Streaming.yml | 13 +-
...s_Java_ParDo_Dataflow_V2_Batch_JavaVersions.yml | 16 +-
...va_ParDo_Dataflow_V2_Streaming_JavaVersions.yml | 16 +-
...s_Java_ParDo_SparkStructuredStreaming_Batch.yml | 13 +-
.../beam_LoadTests_Python_CoGBK_Dataflow_Batch.yml | 8 +-
...m_LoadTests_Python_CoGBK_Dataflow_Streaming.yml | 8 +-
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 6 +-
...eam_LoadTests_Python_Combine_Dataflow_Batch.yml | 31 ++-
...LoadTests_Python_Combine_Dataflow_Streaming.yml | 6 +-
.../beam_LoadTests_Python_Combine_Flink_Batch.yml | 6 +-
...am_LoadTests_Python_Combine_Flink_Streaming.yml | 4 +-
...LoadTests_Python_FnApiRunner_Microbenchmark.yml | 2 +-
.../beam_LoadTests_Python_GBK_Dataflow_Batch.yml | 10 +-
...eam_LoadTests_Python_GBK_Dataflow_Streaming.yml | 2 +-
.../beam_LoadTests_Python_GBK_Flink_Batch.yml | 10 +-
...adTests_Python_GBK_reiterate_Dataflow_Batch.yml | 4 +-
...sts_Python_GBK_reiterate_Dataflow_Streaming.yml | 4 +-
.../beam_LoadTests_Python_ParDo_Dataflow_Batch.yml | 8 +-
...m_LoadTests_Python_ParDo_Dataflow_Streaming.yml | 8 +-
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 6 +-
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 10 +-
...m_LoadTests_Python_SideInput_Dataflow_Batch.yml | 20 +-
.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 | 20 +-
...PerformanceTests_BigQueryIO_Batch_Java_Json.yml | 20 +-
..._PerformanceTests_BigQueryIO_Streaming_Java.yml | 20 +-
...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 | 2 +-
...m_PerformanceTests_Compressed_TextIOIT_HDFS.yml | 2 +-
.../beam_PerformanceTests_HadoopFormat.yml | 4 +-
.github/workflows/beam_PerformanceTests_JDBC.yml | 4 +-
.../workflows/beam_PerformanceTests_Kafka_IO.yml | 7 +-
.../beam_PerformanceTests_ManyFiles_TextIOIT.yml | 4 +-
...am_PerformanceTests_ManyFiles_TextIOIT_HDFS.yml | 4 +-
.../beam_PerformanceTests_MongoDBIO_IT.yml | 4 +-
.../beam_PerformanceTests_ParquetIOIT.yml | 2 +-
.../beam_PerformanceTests_ParquetIOIT_HDFS.yml | 2 +-
...erformanceTests_PubsubIOIT_Python_Streaming.yml | 4 +-
...m_PerformanceTests_SQLBigQueryIO_Batch_Java.yml | 4 +-
.../beam_PerformanceTests_SingleStoreIO.yml | 121 +++++++++
..._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 | 2 +-
.../beam_PerformanceTests_TextIOIT_HDFS.yml | 2 +-
.../beam_PerformanceTests_TextIOIT_Python.yml | 2 +-
...PerformanceTests_WordCountIT_PythonVersions.yml | 4 +-
.../workflows/beam_PerformanceTests_XmlIOIT.yml | 4 +-
.../beam_PerformanceTests_XmlIOIT_HDFS.yml | 4 +-
.../beam_PerformanceTests_xlang_KafkaIO_Python.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow_ARM.yml | 2 +-
...m_PostCommit_Java_Examples_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Dataflow_Java17.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java17.yml | 2 +-
...am_PostCommit_Java_Nexmark_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_TransformService_Direct.yml | 2 +-
.github/workflows/beam_PreCommit_Java.yml | 4 +
...eam_PreCommit_Java_Examples_Dataflow_Java11.yml | 2 +-
...eam_PreCommit_Java_Examples_Dataflow_Java17.yml | 2 +-
...am_PreCommit_Java_RequestResponse_IO_Direct.yml | 2 +-
.github/workflows/beam_PreCommit_SQL_Java11.yml | 2 +-
.github/workflows/beam_PreCommit_SQL_Java17.yml | 2 +-
...config_CoGBK_Java_Streaming_2GB_MultipleKey.txt | 34 ---
...g_CoGBK_Java_Streaming_2GB_Reiteration_10KB.txt | 34 ---
...ig_CoGBK_Java_Streaming_2GB_Reiteration_2MB.txt | 34 ---
.../config_CoGBK_Java_Streaming_2GB_SingleKey.txt | 34 ---
.../config_Combine_Go_Batch_10b.txt | 34 ---
.../config_Combine_Go_Batch_Fanout_4.txt | 34 ---
.../config_Combine_Go_Batch_Fanout_8.txt | 34 ---
.../config_Combine_Python_Batch_2GB_10b.txt | 32 ---
.../config_Combine_Python_Batch_2GB_Fanout_4.txt | 33 ---
.../beam_CloudML_Benchmarks_Dataflow_arguments.txt | 0
..._Pytorch_Imagenet_Classification_Resnet_152.txt | 0
...enet_Classification_Resnet_152_Tesla_T4_GPU.txt | 0
...Pytorch_Language_Modeling_Bert_Base_Uncased.txt | 0
...ytorch_Language_Modeling_Bert_Large_Uncased.txt | 0
...ow_Pytorch_Vision_Classification_Resnet_101.txt | 0
.../go_CoGBK_Dataflow_Batch_MultipleKey.txt} | 0
.../go_CoGBK_Dataflow_Batch_Reiteration_10KB.txt} | 0
.../go_CoGBK_Dataflow_Batch_Reiteration_2MB.txt} | 0
.../go_CoGBK_Dataflow_Batch_SingleKey.txt} | 0
.../go_CoGBK_Flink_Batch_MultipleKey.txt | 0
.../go_CoGBK_Flink_Batch_Reiteration_10KB.txt | 0
.../go_CoGBK_Flink_Batch_Reiteration_2MB.txt | 0
.../go_Combine_Dataflow_Batch_10b.txt} | 4 +-
.../go_Combine_Dataflow_Batch_Fanout_4.txt} | 4 +-
.../go_Combine_Dataflow_Batch_Fanout_8.txt} | 4 +-
.../go_Combine_Flink_Batch_10b.txt | 0
.../go_Combine_Flink_Batch_Fanout_4.txt | 0
.../go_Combine_Flink_Batch_Fanout_8.txt | 0
.../go_GBK_Dataflow_Batch_100b.txt | 0
.../go_GBK_Dataflow_Batch_100kb.txt | 0
.../go_GBK_Dataflow_Batch_10b.txt | 0
.../go_GBK_Dataflow_Batch_Fanout_4.txt | 0
.../go_GBK_Dataflow_Batch_Fanout_8.txt | 0
.../go_GBK_Dataflow_Batch_Reiteration_10KB.txt | 0
.../go_GBK_Dataflow_Batch_Reiteration_2MB.txt | 0
.../go_GBK_Flink_Batch_100b.txt | 0
.../go_GBK_Flink_Batch_100kb.txt | 0
.../go_GBK_Flink_Batch_10b.txt | 0
.../go_GBK_Flink_Batch_Fanout_4.txt | 0
.../go_GBK_Flink_Batch_Fanout_8.txt | 0
.../go_GBK_Flink_Batch_Reiteration_10KB.txt | 0
.../go_ParDo_Dataflow_Batch_100_Counters.txt} | 0
.../go_ParDo_Dataflow_Batch_10_Counters.txt} | 0
.../go_ParDo_Dataflow_Batch_10_Iterations.txt} | 0
.../go_ParDo_Dataflow_Batch_200_Iterations.txt} | 0
.../go_ParDo_Flink_Batch_100_counters.txt | 0
.../go_ParDo_Flink_Batch_10_counters.txt | 0
.../go_ParDo_Flink_Batch_10_times.txt | 0
.../go_ParDo_Flink_Batch_200_times.txt | 0
...go_SideInput_Dataflow_Batch_First_Iterable.txt} | 0
.../go_SideInput_Dataflow_Batch_Iterable.txt} | 0
.../go_SideInput_Flink_Batch_First_Iterable.txt | 0
.../go_SideInput_Flink_Batch_Iterable.txt | 0
...ava_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt | 0
.../java_CoGBK_Dataflow_Batch_100b_Single_Key.txt | 0
.../java_CoGBK_Dataflow_Batch_10kB.txt | 0
.../java_CoGBK_Dataflow_Batch_2MB.txt | 0
...a_CoGBK_Dataflow_Streaming_2GB_MultipleKey.txt} | 1 +
...BK_Dataflow_Streaming_2GB_Reiteration_10KB.txt} | 1 +
...GBK_Dataflow_Streaming_2GB_Reiteration_2MB.txt} | 1 +
...ava_CoGBK_Dataflow_Streaming_2GB_SingleKey.txt} | 1 +
...taflow_V2_Streaming_Java_100b_Multiple_Keys.txt | 0
..._Dataflow_V2_Streaming_Java_100b_Single_Key.txt | 0
.../java_CoGBK_Dataflow_V2_Streaming_Java_10kB.txt | 0
.../java_CoGBK_Dataflow_V2_Streaming_Java_2MB.txt | 0
...tructuredStreaming_Batch_100b_Multiple_Keys.txt | 0
...rkStructuredStreaming_Batch_100b_Single_Key.txt | 0
...a_CoGBK_SparkStructuredStreaming_Batch_10kB.txt | 0
...va_CoGBK_SparkStructuredStreaming_Batch_2MB.txt | 0
.../java_Combine_Dataflow_Batch_10b.txt} | 0
.../java_Combine_Dataflow_Batch_Fanout_4.txt} | 0
.../java_Combine_Dataflow_Batch_Fanout_8.txt} | 0
.../java_Combine_Dataflow_Streaming_10b.txt | 0
.../java_Combine_Dataflow_Streaming_Fanout_4.txt | 0
.../java_Combine_Dataflow_Streaming_Fanout_8.txt | 0
..._Combine_SparkStructuredStreaming_Batch_10b.txt | 0
...ine_SparkStructuredStreaming_Batch_Fanout_4.txt | 0
...ine_SparkStructuredStreaming_Batch_Fanout_8.txt | 0
...java_GBK_Dataflow_Batch_2GB_of_100B_records.txt | 0
...ava_GBK_Dataflow_Batch_2GB_of_100kB_records.txt | 0
.../java_GBK_Dataflow_Batch_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
...ataflow_Batch_reiterate_4_times_10kB_values.txt | 0
...Dataflow_Batch_reiterate_4_times_2MB_values.txt | 0
..._GBK_Dataflow_Streaming_2GB_of_100B_records.txt | 0
...GBK_Dataflow_Streaming_2GB_of_100kB_records.txt | 0
...a_GBK_Dataflow_Streaming_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
...low_Streaming_reiterate_4_times_10kB_values.txt | 0
...flow_Streaming_reiterate_4_times_2MB_values.txt | 0
...ataflow_V2_Batch_Java11_2GB_of_100B_records.txt | 0
...taflow_V2_Batch_Java11_2GB_of_100kB_records.txt | 0
...Dataflow_V2_Batch_Java11_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
..._Batch_Java11_reiterate_4_times_10kB_values.txt | 0
...2_Batch_Java11_reiterate_4_times_2MB_values.txt | 0
...ataflow_V2_Batch_Java17_2GB_of_100B_records.txt | 0
...taflow_V2_Batch_Java17_2GB_of_100kB_records.txt | 0
...Dataflow_V2_Batch_Java17_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
..._Batch_Java17_reiterate_4_times_10kB_values.txt | 0
...2_Batch_Java17_reiterate_4_times_2MB_values.txt | 0
...low_V2_Streaming_Java11_2GB_of_100B_records.txt | 0
...ow_V2_Streaming_Java11_2GB_of_100kB_records.txt | 0
...flow_V2_Streaming_Java11_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
...eaming_Java11_reiterate_4_times_10kB_values.txt | 0
...reaming_Java11_reiterate_4_times_2MB_values.txt | 0
...low_V2_Streaming_Java17_2GB_of_100B_records.txt | 0
...ow_V2_Streaming_Java17_2GB_of_100kB_records.txt | 0
...flow_V2_Streaming_Java17_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
...eaming_Java17_reiterate_4_times_10kB_values.txt | 0
...reaming_Java17_reiterate_4_times_2MB_values.txt | 0
...ucturedStreaming_Batch_2GB_of_100B_records.txt} | 0
...cturedStreaming_Batch_2GB_of_100kB_records.txt} | 0
...ructuredStreaming_Batch_2GB_of_10B_records.txt} | 0
...out_4_times_with_2GB_10-byte_records_total.txt} | 0
...out_8_times_with_2GB_10-byte_records_total.txt} | 0
...eaming_Batch_reiterate_4_times_10kB_values.txt} | 0
...reaming_Batch_reiterate_4_times_2MB_values.txt} | 0
..._Smoke_CombineLoadTest_load_test_Dataflow-1.txt | 0
..._Smoke_CombineLoadTest_load_test_Dataflow-2.txt | 0
..._Smoke_CombineLoadTest_load_test_Dataflow-3.txt | 0
.../java_ParDo_Dataflow_Batch_100_counters.txt | 0
.../java_ParDo_Dataflow_Batch_10_counters.txt | 0
.../java_ParDo_Dataflow_Batch_10_times.txt | 0
.../java_ParDo_Dataflow_Batch_200_times.txt | 0
.../java_ParDo_Dataflow_Streaming_100_counters.txt | 0
.../java_ParDo_Dataflow_Streaming_10_counters.txt | 0
.../java_ParDo_Dataflow_Streaming_10_times.txt | 0
.../java_ParDo_Dataflow_Streaming_200_times.txt | 0
...Dataflow_V2_Batch_JavaVersions_100_counters.txt | 0
..._Dataflow_V2_Batch_JavaVersions_10_counters.txt | 0
...rDo_Dataflow_V2_Batch_JavaVersions_10_times.txt | 0
...Do_Dataflow_V2_Batch_JavaVersions_200_times.txt | 0
...flow_V2_Streaming_JavaVersions_100_counters.txt | 0
...aflow_V2_Streaming_JavaVersions_10_counters.txt | 0
...Dataflow_V2_Streaming_JavaVersions_10_times.txt | 0
...ataflow_V2_Streaming_JavaVersions_200_times.txt | 0
...SparkStructuredStreaming_Batch_100_counters.txt | 0
..._SparkStructuredStreaming_Batch_10_counters.txt | 0
...rDo_SparkStructuredStreaming_Batch_10_times.txt | 0
...Do_SparkStructuredStreaming_Batch_200_times.txt | 0
.../java_Smoke_GroupByKey_Dataflow.txt | 0
.../java_Smoke_GroupByKey_Direct.txt | 0
.../java_Smoke_GroupByKey_Flink.txt | 0
.../java_Smoke_GroupByKey_Spark.txt | 0
...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
.../python_Combine_Dataflow_Batch_2GB_10b.txt} | 6 +-
...python_Combine_Dataflow_Batch_2GB_Fanout_4.txt} | 10 +-
...python_Combine_Dataflow_Batch_2GB_Fanout_8.txt} | 7 +-
...bine_Dataflow_Streaming_2GB_10_byte_records.txt | 0
...hon_Combine_Dataflow_Streaming_2GB_Fanout_4.txt | 0
...hon_Combine_Dataflow_Streaming_2GB_Fanout_8.txt | 0
...hon_Combine_Flink_Batch_2GB_10_byte_records.txt | 0
.../python_Combine_Flink_Batch_2GB_Fanout_4.txt | 0
.../python_Combine_Flink_Batch_2GB_Fanout_8.txt | 0
...Combine_Flink_Streaming_2GB_10_byte_records.txt | 0
...python_Combine_Flink_Streaming_2GB_Fanout_4.txt | 0
...python_Combine_Flink_Streaming_2GB_Fanout_8.txt | 0
.../python_FnApiRunner_Microbenchmark.txt} | 0
...thon_GBK_Dataflow_Batch_2GB_of_100B_records.txt | 0
...hon_GBK_Dataflow_Batch_2GB_of_100kB_records.txt | 0
...ython_GBK_Dataflow_Batch_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
..._GBK_Dataflow_Streaming_2GB_of_100B_records.txt | 0
...GBK_Dataflow_Streaming_2GB_of_100kB_records.txt | 0
...n_GBK_Dataflow_Streaming_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
.../python_GBK_Flink_Batch_2GB_of_100B_records.txt | 0
.../python_GBK_Flink_Batch_2GB_of_10B_records.txt | 0
...nout_4_times_with_2GB_10-byte_records_total.txt | 0
...nout_8_times_with_2GB_10-byte_records_total.txt | 0
...K_Flink_Batch_reiterate_4_times_10kB_values.txt | 0
...ataflow_Batch_reiterate_4_times_10kB_values.txt | 0
...Dataflow_Batch_reiterate_4_times_2MB_values.txt | 0
...low_Streaming_reiterate_4_times_10kB_values.txt | 0
...flow_Streaming_reiterate_4_times_2MB_values.txt | 0
.../python_ParDo_Dataflow_Batch_100_Counters.txt | 0
.../python_ParDo_Dataflow_Batch_10_Counters.txt | 0
.../python_ParDo_Dataflow_Batch_10_Iterations.txt | 0
.../python_ParDo_Dataflow_Batch_200_Iterations.txt | 0
...ython_ParDo_Dataflow_Streaming_100_Counters.txt | 0
...python_ParDo_Dataflow_Streaming_10_Counters.txt | 0
...thon_ParDo_Dataflow_Streaming_10_Iterations.txt | 0
...hon_ParDo_Dataflow_Streaming_200_Iterations.txt | 0
.../python_ParDo_Flink_Batch_10_Counters.txt | 0
.../python_ParDo_Flink_Batch_10_Iterations.txt | 0
.../python_ParDo_Flink_Batch_200_Iterations.txt | 0
.../python_ParDo_Flink_Streaming_100_Counters.txt | 0
.../python_ParDo_Flink_Streaming_10_Counters.txt | 0
.../python_ParDo_Flink_Streaming_10_Iterations.txt | 0
...python_ParDo_Flink_Streaming_200_Iterations.txt | 0
.../python_ParDo_Flink_Streaming_5_Iterations.txt | 0
...taflow_Batch_10gb_1000window_first_iterable.txt | 0
...put_Dataflow_Batch_10gb_1000window_iterable.txt | 0
..._Dataflow_Batch_10gb_1window_first_iterable.txt | 0
...eInput_Dataflow_Batch_10gb_1window_iterable.txt | 0
...flow_Batch_1gb_1000window_1key_percent_dict.txt | 0
...low_Batch_1gb_1000window_99key_percent_dict.txt | 0
...ataflow_Batch_1gb_1window_1key_percent_dict.txt | 0
...taflow_Batch_1gb_1window_99key_percent_dict.txt | 0
...Input_Dataflow_Batch_1gb_1window_first_list.txt | 0
...n_SideInput_Dataflow_Batch_1gb_1window_list.txt | 0
.../python_Smoke_GroupByKey_Dataflow.txt | 0
.../python_Smoke_GroupByKey_Direct.txt | 0
.../config_BigQueryIO_Batch_Java_Avro.txt | 38 ---
.../config_BigQueryIO_Batch_Java_Json.txt | 38 ---
.../config_BigQueryIO_Streaming_Java.txt | 39 ---
...t => config_PerformanceTests_SingleStoreIO.txt} | 12 +-
.../JDBC.txt | 0
.../SQLBigQueryIO_Batch_Java.txt | 0
.../TFRecordIOIT.txt} | 0
.../TFRecordIOIT_HDFS.txt | 0
.../avroIOIT.txt} | 0
.../avroIOIT_HDFS.txt} | 0
.../bigQueryIO_Batch_Java_Avro.txt} | 7 +-
.../bigQueryIO_Batch_Java_Json.txt} | 7 +-
.../bigQueryIO_Streaming_Java.txt} | 8 +-
.../biqQueryIO_Read_Python.txt | 0
.../biqQueryIO_Write_Python_Batch.txt | 0
.../cdap.txt | 0
.../compressed_TextIOIT.txt} | 0
.../compressed_TextIOIT_HDFS.txt} | 0
.../hadoopFormat.txt | 0
.../kafka_IO_Batch.txt | 0
.../kafka_IO_Streaming.txt | 0
.../manyFiles_TextIOIT.txt} | 0
.../manyFiles_TextIOIT_HDFS.txt} | 0
.../mongoDBIO_IT.txt | 0
.../parquetIOIT.txt} | 0
.../parquetIOIT_HDFS.txt} | 0
.../pubsubIOIT_Python_Streaming.txt | 0
.../spannerIO_Read_2GB_Python.txt | 0
.../spannerIO_Write_2GB_Python.txt | 0
.../sparkReceiver_IO.txt | 0
.../textIOIT.txt | 0
.../textIOIT_HDFS.txt | 0
.../textIOIT_Python.txt | 0
.../wordCountIT_Python.txt | 0
.../xlang_KafkaIO_Python.txt | 0
.../xmlIOIT.txt} | 0
.../xmlIOIT_HDFS.txt} | 0
.test-infra/jenkins/JavaTestProperties.groovy | 7 +-
.test-infra/jenkins/NexmarkBuilder.groovy | 4 +-
.../job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy | 2 +-
.../job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy | 2 +-
.../job_LoadTests_GBK_Dataflow_V2_Java11.groovy | 2 +-
.../job_LoadTests_GBK_Dataflow_V2_Java17.groovy | 2 +-
.../job_LoadTests_ParDo_Dataflow_V2_Java11.groovy | 2 +-
.../job_LoadTests_ParDo_Dataflow_V2_Java17.groovy | 2 +-
...tCommit_Java_Examples_Dataflow_V2_Java11.groovy | 2 +-
...tCommit_Java_Examples_Dataflow_V2_Java17.groovy | 2 +-
...job_PostCommit_Java_Jpms_Dataflow_Java17.groovy | 2 +-
.../job_PostCommit_Java_Jpms_Direct_Java17.groovy | 2 +-
.../job_PostCommit_TransformService_Direct.groovy | 2 +-
.test-infra/jenkins/job_PreCommit_Java.groovy | 1 +
build.gradle.kts | 16 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 37 ++-
learning/katas/go/go.mod | 2 +-
learning/katas/go/go.sum | 20 +-
.../runners/core/construction/Environments.java | 6 +-
.../core/construction/EnvironmentsTest.java | 6 +-
.../google-cloud-dataflow-java/arm/build.gradle | 6 +-
runners/google-cloud-dataflow-java/build.gradle | 6 +-
.../beam/runners/dataflow/DataflowRunner.java | 7 +-
.../dataflow/worker/DataflowOperationContext.java | 7 +-
.../beam/runners/dataflow/worker/StateFetcher.java | 291 ---------------------
.../dataflow/worker/StreamingDataflowWorker.java | 11 +-
.../worker/StreamingModeExecutionContext.java | 114 ++++----
.../dataflow/worker/StreamingSideInputFetcher.java | 8 +-
.../worker/streaming/sideinput/SideInput.java | 50 ++++
.../worker/streaming/sideinput/SideInputCache.java | 113 ++++++++
.../worker/streaming/sideinput/SideInputState.java | 8 +-
.../streaming/sideinput/SideInputStateFetcher.java | 245 +++++++++++++++++
.../worker/StreamingDataflowWorkerTest.java | 6 +-
.../worker/StreamingModeExecutionContextTest.java | 9 +-
.../worker/StreamingSideInputDoFnRunnerTest.java | 2 +-
.../worker/StreamingSideInputFetcherTest.java | 2 +-
.../sideinput/SideInputStateFetcherTest.java} | 170 +++++++-----
runners/spark/spark_runner.gradle | 5 +-
sdks/go.mod | 6 +-
sdks/go.sum | 12 +-
sdks/java/container/Dockerfile | 3 +-
sdks/java/container/agent/build.gradle | 14 +-
sdks/java/container/common.gradle | 28 +-
.../java/container/java21/build.gradle | 17 +-
sdks/java/container/java21/option-jamm.json | 12 +
.../org/apache/beam/sdk/coders/CoderProviders.java | 7 +-
.../org/apache/beam/sdk/coders/DefaultCoder.java | 8 +
sdks/java/io/splunk/build.gradle | 1 +
.../beam/sdk/io/splunk/HttpEventPublisher.java | 9 +
.../org/apache/beam/sdk/io/splunk/SplunkEvent.java | 21 +-
.../beam/sdk/io/splunk/SplunkEventCoder.java | 206 +++++++++++++++
.../beam/sdk/io/splunk/SplunkEventWriter.java | 65 ++++-
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 1 -
.../beam/sdk/io/splunk/SplunkEventCoderTest.java | 228 ++++++++++++++++
.../apache/beam/sdk/io/splunk/SplunkEventTest.java | 5 +
.../beam/sdk/io/splunk/SplunkEventWriterTest.java | 63 ++++-
.../apache/beam/sdk/io/splunk/SplunkIOTest.java | 12 +-
sdks/java/testing/jpms-tests/build.gradle | 25 +-
sdks/java/testing/test-utils/build.gradle | 29 +-
.../testutils/jvmverification/JvmVerification.java | 16 +-
sdks/python/apache_beam/dataframe/io.py | 5 +-
sdks/python/apache_beam/yaml/README.md | 177 +++++++------
sdks/python/apache_beam/yaml/json_utils.py | 40 ++-
sdks/python/apache_beam/yaml/main.py | 5 +-
sdks/python/apache_beam/yaml/pipeline.schema.yaml | 48 +++-
sdks/python/apache_beam/yaml/yaml_io.py | 10 +-
sdks/python/apache_beam/yaml/yaml_io_test.py | 38 ++-
sdks/python/apache_beam/yaml/yaml_mapping_test.py | 4 -
sdks/python/apache_beam/yaml/yaml_transform.py | 12 +-
.../python/apache_beam/yaml/yaml_transform_test.py | 12 +-
.../apache_beam/yaml/yaml_transform_unit_test.py | 2 -
sdks/python/apache_beam/yaml/yaml_udf_test.py | 8 -
.../container/py310/base_image_requirements.txt | 8 +-
.../container/py311/base_image_requirements.txt | 8 +-
.../container/py38/base_image_requirements.txt | 10 +-
.../container/py39/base_image_requirements.txt | 8 +-
sdks/python/setup.py | 1 +
settings.gradle.kts | 1 +
.../documentation/io/built-in/google-bigquery.md | 39 +--
.../sdks/python-unrecoverable-errors.md | 78 +++---
website/www/site/content/en/get-started/_index.md | 26 +-
.../www/site/content/en/get-started/downloads.md | 2 +-
website/www/site/content/en/roadmap/java-sdk.md | 6 +-
444 files changed, 2461 insertions(+), 1645 deletions(-)
create mode 100644 .github/workflows/beam_PerformanceTests_SingleStoreIO.yml
delete mode 100644
.github/workflows/load-tests-job-configs/config_CoGBK_Java_Streaming_2GB_MultipleKey.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_CoGBK_Java_Streaming_2GB_Reiteration_10KB.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_CoGBK_Java_Streaming_2GB_Reiteration_2MB.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_CoGBK_Java_Streaming_2GB_SingleKey.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_Combine_Go_Batch_10b.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_Combine_Go_Batch_Fanout_4.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_Combine_Go_Batch_Fanout_8.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_Combine_Python_Batch_2GB_10b.txt
delete mode 100644
.github/workflows/load-tests-job-configs/config_Combine_Python_Batch_2GB_Fanout_4.txt
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/beam_CloudML_Benchmarks_Dataflow_arguments.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Imagenet_Classification_Resnet_152.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Imagenet_Classification_Resnet_152_Tesla_T4_GPU.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Language_Modeling_Bert_Base_Uncased.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Language_Modeling_Bert_Large_Uncased.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Vision_Classification_Resnet_101.txt
(100%)
rename
.github/workflows/{load-tests-job-configs/config_CoGBK_Go_Batch_MultipleKey.txt
=> load-tests-pipeline-options/go_CoGBK_Dataflow_Batch_MultipleKey.txt} (100%)
rename
.github/workflows/{load-tests-job-configs/config_CoGBK_Go_Batch_Reiteration_10KB.txt
=> load-tests-pipeline-options/go_CoGBK_Dataflow_Batch_Reiteration_10KB.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/config_CoGBK_Go_Batch_Reiteration_2MB.txt
=> load-tests-pipeline-options/go_CoGBK_Dataflow_Batch_Reiteration_2MB.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/config_CoGBK_Go_Batch_SingleKey.txt
=> load-tests-pipeline-options/go_CoGBK_Dataflow_Batch_SingleKey.txt} (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_CoGBK_Flink_Batch_MultipleKey.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_CoGBK_Flink_Batch_Reiteration_10KB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_CoGBK_Flink_Batch_Reiteration_2MB.txt (100%)
copy .github/workflows/{load-tests-job-configs/go_GBK_Dataflow_Batch_10b.txt
=> load-tests-pipeline-options/go_Combine_Dataflow_Batch_10b.txt} (93%)
copy
.github/workflows/{load-tests-job-configs/go_GBK_Dataflow_Batch_Fanout_4.txt =>
load-tests-pipeline-options/go_Combine_Dataflow_Batch_Fanout_4.txt} (93%)
copy
.github/workflows/{load-tests-job-configs/go_GBK_Dataflow_Batch_Fanout_8.txt =>
load-tests-pipeline-options/go_Combine_Dataflow_Batch_Fanout_8.txt} (93%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_Combine_Flink_Batch_10b.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_Combine_Flink_Batch_Fanout_4.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_Combine_Flink_Batch_Fanout_8.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_100b.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_100kb.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_10b.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_Fanout_4.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_Fanout_8.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_Reiteration_10KB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Dataflow_Batch_Reiteration_2MB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Flink_Batch_100b.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Flink_Batch_100kb.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Flink_Batch_10b.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Flink_Batch_Fanout_4.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Flink_Batch_Fanout_8.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_GBK_Flink_Batch_Reiteration_10KB.txt (100%)
rename
.github/workflows/{load-tests-job-configs/config_ParDo_Go_Batch_100_Counters.txt
=> load-tests-pipeline-options/go_ParDo_Dataflow_Batch_100_Counters.txt} (100%)
rename
.github/workflows/{load-tests-job-configs/config_ParDo_Go_Batch_10_Counters.txt
=> load-tests-pipeline-options/go_ParDo_Dataflow_Batch_10_Counters.txt} (100%)
rename
.github/workflows/{load-tests-job-configs/config_ParDo_Go_Batch_10_Iterations.txt
=> load-tests-pipeline-options/go_ParDo_Dataflow_Batch_10_Iterations.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/config_ParDo_Go_Batch_200_Iterations.txt
=> load-tests-pipeline-options/go_ParDo_Dataflow_Batch_200_Iterations.txt}
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_ParDo_Flink_Batch_100_counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_ParDo_Flink_Batch_10_counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_ParDo_Flink_Batch_10_times.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_ParDo_Flink_Batch_200_times.txt (100%)
rename
.github/workflows/{load-tests-job-configs/config_SideInput_Go_Batch_Dataflow_First_Iterable.txt
=> load-tests-pipeline-options/go_SideInput_Dataflow_Batch_First_Iterable.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/config_SideInput_Go_Batch_Dataflow_Iterable.txt
=> load-tests-pipeline-options/go_SideInput_Dataflow_Batch_Iterable.txt} (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_SideInput_Flink_Batch_First_Iterable.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/go_SideInput_Flink_Batch_Iterable.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_Batch_100b_Single_Key.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_Batch_10kB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_Batch_2MB.txt (100%)
copy
.github/workflows/{load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_100b_Multiple_Keys.txt
=>
load-tests-pipeline-options/java_CoGBK_Dataflow_Streaming_2GB_MultipleKey.txt}
(94%)
copy
.github/workflows/{load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_10kB.txt
=>
load-tests-pipeline-options/java_CoGBK_Dataflow_Streaming_2GB_Reiteration_10KB.txt}
(94%)
copy
.github/workflows/{load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_2MB.txt
=>
load-tests-pipeline-options/java_CoGBK_Dataflow_Streaming_2GB_Reiteration_2MB.txt}
(94%)
copy
.github/workflows/{load-tests-job-configs/java_CoGBK_Dataflow_V2_Streaming_Java_100b_Single_Key.txt
=>
load-tests-pipeline-options/java_CoGBK_Dataflow_Streaming_2GB_SingleKey.txt}
(94%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_V2_Streaming_Java_100b_Multiple_Keys.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_V2_Streaming_Java_100b_Single_Key.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_V2_Streaming_Java_10kB.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_Dataflow_V2_Streaming_Java_2MB.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_SparkStructuredStreaming_Batch_100b_Multiple_Keys.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_SparkStructuredStreaming_Batch_100b_Single_Key.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_SparkStructuredStreaming_Batch_10kB.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_CoGBK_SparkStructuredStreaming_Batch_2MB.txt
(100%)
rename
.github/workflows/{load-tests-job-configs/config_Combine_Java_Dataflow_Batch_10b.txt
=> load-tests-pipeline-options/java_Combine_Dataflow_Batch_10b.txt} (100%)
rename
.github/workflows/{load-tests-job-configs/config_Combine_Java_Dataflow_Batch_Fanout_4.txt
=> load-tests-pipeline-options/java_Combine_Dataflow_Batch_Fanout_4.txt} (100%)
rename
.github/workflows/{load-tests-job-configs/config_Combine_Java_Dataflow_Batch_Fanout_8.txt
=> load-tests-pipeline-options/java_Combine_Dataflow_Batch_Fanout_8.txt} (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Combine_Dataflow_Streaming_10b.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Combine_Dataflow_Streaming_Fanout_4.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Combine_Dataflow_Streaming_Fanout_8.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Combine_SparkStructuredStreaming_Batch_10b.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Combine_SparkStructuredStreaming_Batch_Fanout_4.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Combine_SparkStructuredStreaming_Batch_Fanout_8.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Batch_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_Streaming_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java11_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Batch_Java17_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java11_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_GBK_Dataflow_V2_Streaming_Java17_reiterate_4_times_2MB_values.txt
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_2GB_of_100B_records.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_2GB_of_100B_records.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_2GB_of_100kB_records.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_2GB_of_100kB_records.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_2GB_of_10B_records.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_2GB_of_10B_records.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_fanout_4_times_with_2GB_10-byte_records_total.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_fanout_4_times_with_2GB_10-byte_records_total.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_fanout_8_times_with_2GB_10-byte_records_total.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_fanout_8_times_with_2GB_10-byte_records_total.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_reiterate_4_times_10kB_values.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_reiterate_4_times_10kB_values.txt}
(100%)
rename
.github/workflows/{load-tests-job-configs/Java_GBK_SparkStructuredStreaming_Batch_reiterate_4_times_2MB_values.txt
=>
load-tests-pipeline-options/java_GBK_SparkStructuredStreaming_Batch_reiterate_4_times_2MB_values.txt}
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_LoadTests_Combine_Smoke_CombineLoadTest_load_test_Dataflow-1.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_LoadTests_Combine_Smoke_CombineLoadTest_load_test_Dataflow-2.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_LoadTests_Combine_Smoke_CombineLoadTest_load_test_Dataflow-3.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Batch_100_counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Batch_10_counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Batch_10_times.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Batch_200_times.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Streaming_100_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Streaming_10_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Streaming_10_times.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_Streaming_200_times.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Batch_JavaVersions_100_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Batch_JavaVersions_10_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Batch_JavaVersions_10_times.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Batch_JavaVersions_200_times.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Streaming_JavaVersions_100_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Streaming_JavaVersions_10_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Streaming_JavaVersions_10_times.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_Dataflow_V2_Streaming_JavaVersions_200_times.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_SparkStructuredStreaming_Batch_100_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_SparkStructuredStreaming_Batch_10_counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_SparkStructuredStreaming_Batch_10_times.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_ParDo_SparkStructuredStreaming_Batch_200_times.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Smoke_GroupByKey_Dataflow.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Smoke_GroupByKey_Direct.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Smoke_GroupByKey_Flink.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/java_Smoke_GroupByKey_Spark.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Batch_100b_Multiple_Keys.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Batch_100b_Single_Key.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Batch_10kB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Batch_2MB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Flink_Batch_10kB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Streaming_100b_Multiple_Keys.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Streaming_100b_Single_Key.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Streaming_10kB.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_CoGBK_Dataflow_Streaming_2MB.txt (100%)
copy
.github/workflows/{load-tests-job-configs/python_Combine_Dataflow_Streaming_2GB_10_byte_records.txt
=> load-tests-pipeline-options/python_Combine_Dataflow_Batch_2GB_10b.txt} (87%)
copy
.github/workflows/{load-tests-job-configs/python_Combine_Dataflow_Streaming_2GB_Fanout_4.txt
=> load-tests-pipeline-options/python_Combine_Dataflow_Batch_2GB_Fanout_4.txt}
(82%)
rename
.github/workflows/{load-tests-job-configs/config_Combine_Python_Batch_2GB_Fanout_8.txt
=> load-tests-pipeline-options/python_Combine_Dataflow_Batch_2GB_Fanout_8.txt}
(78%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Dataflow_Streaming_2GB_10_byte_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Dataflow_Streaming_2GB_Fanout_4.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Dataflow_Streaming_2GB_Fanout_8.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Flink_Batch_2GB_10_byte_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Flink_Batch_2GB_Fanout_4.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Flink_Batch_2GB_Fanout_8.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Flink_Streaming_2GB_10_byte_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Flink_Streaming_2GB_Fanout_4.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Combine_Flink_Streaming_2GB_Fanout_8.txt
(100%)
rename
.github/workflows/{load-tests-job-configs/config_FnApiRunner_Python_Microbenchmark.txt
=> load-tests-pipeline-options/python_FnApiRunner_Microbenchmark.txt} (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Batch_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Batch_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Batch_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Batch_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Batch_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Streaming_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Streaming_2GB_of_100kB_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Streaming_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Streaming_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Dataflow_Streaming_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Flink_Batch_2GB_of_100B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Flink_Batch_2GB_of_10B_records.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Flink_Batch_fanout_4_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Flink_Batch_fanout_8_times_with_2GB_10-byte_records_total.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_Flink_Batch_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_reiterate_Dataflow_Batch_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_reiterate_Dataflow_Batch_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_reiterate_Dataflow_Streaming_reiterate_4_times_10kB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_GBK_reiterate_Dataflow_Streaming_reiterate_4_times_2MB_values.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Batch_100_Counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Batch_10_Counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Batch_10_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Batch_200_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Streaming_100_Counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Streaming_10_Counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Streaming_10_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Dataflow_Streaming_200_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Batch_10_Counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Batch_10_Iterations.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Batch_200_Iterations.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Streaming_100_Counters.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Streaming_10_Counters.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Streaming_10_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Streaming_200_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_ParDo_Flink_Streaming_5_Iterations.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_10gb_1000window_first_iterable.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_10gb_1000window_iterable.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_10gb_1window_first_iterable.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_10gb_1window_iterable.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_1gb_1000window_1key_percent_dict.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_1gb_1000window_99key_percent_dict.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_1gb_1window_1key_percent_dict.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_1gb_1window_99key_percent_dict.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_1gb_1window_first_list.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_SideInput_Dataflow_Batch_1gb_1window_list.txt
(100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Smoke_GroupByKey_Dataflow.txt (100%)
rename .github/workflows/{load-tests-job-configs =>
load-tests-pipeline-options}/python_Smoke_GroupByKey_Direct.txt (100%)
delete mode 100644
.github/workflows/performance-tests-job-configs/config_BigQueryIO_Batch_Java_Avro.txt
delete mode 100644
.github/workflows/performance-tests-job-configs/config_BigQueryIO_Batch_Java_Json.txt
delete mode 100644
.github/workflows/performance-tests-job-configs/config_BigQueryIO_Streaming_Java.txt
copy .github/workflows/performance-tests-job-configs/{TFRecordIOIT_HDFS.txt =>
config_PerformanceTests_SingleStoreIO.txt} (84%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/JDBC.txt (100%)
copy .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/SQLBigQueryIO_Batch_Java.txt (100%)
rename
.github/workflows/{performance-tests-job-configs/config_TFRecordIOIT.txt =>
performance-tests-pipeline-options/TFRecordIOIT.txt} (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/TFRecordIOIT_HDFS.txt (100%)
rename .github/workflows/{performance-tests-job-configs/config_AvroIOIT.txt =>
performance-tests-pipeline-options/avroIOIT.txt} (100%)
rename
.github/workflows/{performance-tests-job-configs/config_AvroIOIT_HDFS.txt =>
performance-tests-pipeline-options/avroIOIT_HDFS.txt} (100%)
copy
.github/workflows/{performance-tests-job-configs/SQLBigQueryIO_Batch_Java.txt
=> performance-tests-pipeline-options/bigQueryIO_Batch_Java_Avro.txt} (76%)
copy
.github/workflows/{performance-tests-job-configs/SQLBigQueryIO_Batch_Java.txt
=> performance-tests-pipeline-options/bigQueryIO_Batch_Java_Json.txt} (76%)
rename
.github/workflows/{performance-tests-job-configs/SQLBigQueryIO_Batch_Java.txt
=> performance-tests-pipeline-options/bigQueryIO_Streaming_Java.txt} (74%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/biqQueryIO_Read_Python.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/biqQueryIO_Write_Python_Batch.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/cdap.txt (100%)
rename
.github/workflows/{performance-tests-job-configs/config_Compressed_TextIOIT.txt
=> performance-tests-pipeline-options/compressed_TextIOIT.txt} (100%)
rename
.github/workflows/{performance-tests-job-configs/config_Compressed_TextIOIT_HDFS.txt
=> performance-tests-pipeline-options/compressed_TextIOIT_HDFS.txt} (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/hadoopFormat.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/kafka_IO_Batch.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/kafka_IO_Streaming.txt (100%)
rename
.github/workflows/{performance-tests-job-configs/config_ManyFiles_TextIOIT.txt
=> performance-tests-pipeline-options/manyFiles_TextIOIT.txt} (100%)
rename
.github/workflows/{performance-tests-job-configs/config_ManyFiles_TextIOIT_HDFS.txt
=> performance-tests-pipeline-options/manyFiles_TextIOIT_HDFS.txt} (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/mongoDBIO_IT.txt (100%)
rename .github/workflows/{performance-tests-job-configs/config_ParquetIOIT.txt
=> performance-tests-pipeline-options/parquetIOIT.txt} (100%)
rename
.github/workflows/{performance-tests-job-configs/config_ParquetIOIT_HDFS.txt =>
performance-tests-pipeline-options/parquetIOIT_HDFS.txt} (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/pubsubIOIT_Python_Streaming.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/spannerIO_Read_2GB_Python.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/spannerIO_Write_2GB_Python.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/sparkReceiver_IO.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/textIOIT.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/textIOIT_HDFS.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/textIOIT_Python.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/wordCountIT_Python.txt (100%)
rename .github/workflows/{performance-tests-job-configs =>
performance-tests-pipeline-options}/xlang_KafkaIO_Python.txt (100%)
rename .github/workflows/{performance-tests-job-configs/config_XmlIOIT.txt =>
performance-tests-pipeline-options/xmlIOIT.txt} (100%)
rename
.github/workflows/{performance-tests-job-configs/config_XmlIOIT_HDFS.txt =>
performance-tests-pipeline-options/xmlIOIT_HDFS.txt} (100%)
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StateFetcher.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/sideinput/SideInput.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/sideinput/SideInputCache.java
copy .test-infra/jenkins/JavaTestProperties.groovy =>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/sideinput/SideInputState.java
(77%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/sideinput/SideInputStateFetcher.java
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{StateFetcherTest.java
=> streaming/sideinput/SideInputStateFetcherTest.java} (67%)
copy .test-infra/jenkins/JavaTestProperties.groovy =>
sdks/java/container/java21/build.gradle (59%)
create mode 100644 sdks/java/container/java21/option-jamm.json
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEventCoder.java
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/SplunkEventCoderTest.java
