This is an automated email from the ASF dual-hosted git repository. Abacn pushed a commit to branch restore-load in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5ff7edb2673f2e3176de60c897ab9df352216f3d Author: Yi Hu <[email protected]> AuthorDate: Thu Aug 13 14:00:25 2026 -0400 Restore Go Flink load test parameters --- .../load-tests-pipeline-options/go_CoGBK_Flink_Batch_MultipleKey.txt | 4 ++-- .../go_CoGBK_Flink_Batch_Reiteration_10KB.txt | 4 ++-- .../go_CoGBK_Flink_Batch_Reiteration_2MB.txt | 4 ++-- .../load-tests-pipeline-options/go_Combine_Flink_Batch_10b.txt | 2 +- .../load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_4.txt | 2 +- .../load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_8.txt | 2 +- .../workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100b.txt | 2 +- .../load-tests-pipeline-options/go_GBK_Flink_Batch_100kb.txt | 2 +- .../workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_10b.txt | 2 +- .../load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_4.txt | 2 +- .../load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_8.txt | 2 +- .../go_GBK_Flink_Batch_Reiteration_10KB.txt | 2 +- .../go_SideInput_Flink_Batch_First_Iterable.txt | 2 +- .../load-tests-pipeline-options/go_SideInput_Flink_Batch_Iterable.txt | 2 +- 14 files changed, 17 insertions(+), 17 deletions(-) diff --git a/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_MultipleKey.txt b/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_MultipleKey.txt index 504b464eb1f..ec2c5c3e040 100644 --- a/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_MultipleKey.txt +++ b/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_MultipleKey.txt @@ -16,8 +16,8 @@ --influx_measurement=go_batch_cogbk_1 --influx_namespace=flink ---input_options=''{\"num_records\":10000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":5,\"hot_key_fraction\":1}'' ---co_input_options=''{\"num_records\":1000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":1000,\"hot_key_fraction\":1}'' +--input_options=''{\"num_records\":1000000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":5,\"hot_key_fraction\":1}'' +--co_input_options=''{\"num_records\":100000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":1000,\"hot_key_fraction\":1}'' --iterations=1 --parallelism=5 --endpoint=localhost:8099 diff --git a/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_10KB.txt b/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_10KB.txt index 7eb9a3c8053..7698c7aa7c7 100644 --- a/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_10KB.txt +++ b/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_10KB.txt @@ -16,8 +16,8 @@ --influx_measurement=go_batch_cogbk_2 --influx_namespace=flink ---input_options=''{\"num_records\":10000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":1000,\"hot_key_fraction\":1}'' ---co_input_options=''{\"num_records\":1000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":10,\"hot_key_fraction\":1}'' +--input_options=''{\"num_records\":1000000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":100000,\"hot_key_fraction\":1}'' +--co_input_options=''{\"num_records\":100000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":1000,\"hot_key_fraction\":1}'' --iterations=4 --parallelism=5 --endpoint=localhost:8099 diff --git a/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_2MB.txt b/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_2MB.txt index ccf5ae7cbf2..c6b1f5fcc33 100644 --- a/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_2MB.txt +++ b/.github/workflows/load-tests-pipeline-options/go_CoGBK_Flink_Batch_Reiteration_2MB.txt @@ -16,8 +16,8 @@ --influx_measurement=go_batch_cogbk_3 --influx_namespace=flink ---input_options=''{\"num_records\":100,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":100,\"hot_key_fraction\":1}'' ---co_input_options=''{\"num_records\":10,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":10,\"hot_key_fraction\":1}'' +--input_options=''{\"num_records\":1000000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":1000,\"hot_key_fraction\":1}'' +--co_input_options=''{\"num_records\":100000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":1000,\"hot_key_fraction\":1}'' --iterations=4 --parallelism=5 --endpoint=localhost:8099 diff --git a/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_10b.txt b/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_10b.txt index 11a746e3225..6e13d4e185c 100644 --- a/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_10b.txt +++ b/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_10b.txt @@ -16,7 +16,7 @@ --influx_namespace=flink --influx_measurement=go_batch_combine_1 ---input_options=''{\"num_records\":2000000,\"key_size\":1,\"value_size\":9}'' +--input_options=''{\"num_records\":200000000,\"key_size\":1,\"value_size\":9}'' --fanout=1 --top_count=20 --parallelism=5 diff --git a/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_4.txt b/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_4.txt index 7be4e56c2e4..154076a6398 100644 --- a/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_4.txt +++ b/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_4.txt @@ -16,7 +16,7 @@ --influx_namespace=flink --influx_measurement=go_batch_combine_2 ---input_options=''{\"num_records\":25000,\"key_size\":10,\"value_size\":90}'' +--input_options=''{\"num_records\":5000000,\"key_size\":10,\"value_size\":90}'' --fanout=4 --top_count=20 --parallelism=16 diff --git a/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_8.txt b/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_8.txt index 6a0892af72d..05e4dccf74d 100644 --- a/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_8.txt +++ b/.github/workflows/load-tests-pipeline-options/go_Combine_Flink_Batch_Fanout_8.txt @@ -19,7 +19,7 @@ --fanout=8 --top_count=20 --parallelism=16 ---input_options=''{\"num_records\":10000,\"key_size\":10,\"value_size\":90}'' +--input_options=''{\"num_records\":2500000,\"key_size\":10,\"value_size\":90}'' --endpoint=localhost:8099 --environment_type=DOCKER --environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest diff --git a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100b.txt b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100b.txt index 4aded424572..d5c1d865e18 100644 --- a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100b.txt +++ b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100b.txt @@ -16,7 +16,7 @@ --influx_namespace=flink --influx_measurement=go_batch_gbk_2 ---input_options=''{\"num_records\":500000,\"key_size\":10,\"value_size\":90}'' +--input_options=''{\"num_records\":1000000,\"key_size\":10,\"value_size\":90}'' --iterations=1 --fanout=1 --parallelism=5 diff --git a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100kb.txt b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100kb.txt index f02e6984c81..a188f8c0978 100644 --- a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100kb.txt +++ b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_100kb.txt @@ -19,7 +19,7 @@ --iterations=1 --fanout=1 --parallelism=5 ---input_options=''{\"num_records\":50,\"key_size\":10000,\"value_size\":90000}'' +--input_options=''{\"num_records\":1000,\"key_size\":10000,\"value_size\":90000}'' --endpoint=localhost:8099 --environment_type=DOCKER --environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest diff --git a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_10b.txt b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_10b.txt index 4691e2d92ce..0bb35b26436 100644 --- a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_10b.txt +++ b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_10b.txt @@ -16,7 +16,7 @@ --influx_namespace=flink --influx_measurement=go_batch_gbk_1 ---input_options=''{\"num_records\":500000,\"key_size\":1,\"value_size\":9}'' +--input_options=''{\"num_records\":5000000,\"key_size\":1,\"value_size\":9}'' --iterations=1 --fanout=1 --parallelism=5 diff --git a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_4.txt b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_4.txt index 0042a9b80f3..4378d56a8f8 100644 --- a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_4.txt +++ b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_4.txt @@ -19,7 +19,7 @@ --iterations=1 --fanout=4 --parallelism=16 ---input_options=''{\"num_records\":10000,\"key_size\":10,\"value_size\":90}'' +--input_options=''{\"num_records\":100000,\"key_size\":10,\"value_size\":90}'' --endpoint=localhost:8099 --environment_type=DOCKER --environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest diff --git a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_8.txt b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_8.txt index fb14c2da58d..43292d57717 100644 --- a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_8.txt +++ b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Fanout_8.txt @@ -19,7 +19,7 @@ --iterations=1 --fanout=8 --parallelism=16 ---input_options=''{\"num_records\":10000,\"key_size\":10,\"value_size\":90}'' +--input_options=''{\"num_records\":100000,\"key_size\":10,\"value_size\":90}'' --endpoint=localhost:8099 --environment_type=DOCKER --environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest diff --git a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Reiteration_10KB.txt b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Reiteration_10KB.txt index ee220853c60..c4d33c21482 100644 --- a/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Reiteration_10KB.txt +++ b/.github/workflows/load-tests-pipeline-options/go_GBK_Flink_Batch_Reiteration_10KB.txt @@ -19,7 +19,7 @@ --iterations=4 --fanout=1 --parallelism=5 ---input_options=''{\"num_records\":10000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":100,\"hot_key_fraction\":1}'' +--input_options=''{\"num_records\":1000000,\"key_size\":10,\"value_size\":90,\"num_hot_keys\":200,\"hot_key_fraction\":1}'' --endpoint=localhost:8099 --environment_type=DOCKER --environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest diff --git a/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_First_Iterable.txt b/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_First_Iterable.txt index d413484162f..0d50916b8bd 100644 --- a/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_First_Iterable.txt +++ b/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_First_Iterable.txt @@ -16,7 +16,7 @@ --influx_namespace=flink --influx_measurement=go_batch_sideinput_1 ---input_options=''{\"num_records\":20000,\"key_size\":100,\"value_size\":900}'' +--input_options=''{\"num_records\":400000,\"key_size\":100,\"value_size\":900}'' --access_percentage=1 --parallelism=10 --endpoint=localhost:8099 diff --git a/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_Iterable.txt b/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_Iterable.txt index fdefb212948..ca11bc55faa 100644 --- a/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_Iterable.txt +++ b/.github/workflows/load-tests-pipeline-options/go_SideInput_Flink_Batch_Iterable.txt @@ -16,7 +16,7 @@ --influx_namespace=flink --influx_measurement=go_batch_sideinput_2 ---input_options=''{\"num_records\":20000,\"key_size\":100,\"value_size\":900}'' +--input_options=''{\"num_records\":400000,\"key_size\":100,\"value_size\":900}'' --parallelism=10 --endpoint=localhost:8099 --environment_type=DOCKER
