This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-prism-runner-log-level
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/fix-prism-runner-log-level by
this push:
new 9c013608ede Fix runner
9c013608ede is described below
commit 9c013608ede5edc1b696599aaa4fc30d9e5d6336
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Thu Sep 4 16:55:12 2025 +0400
Fix runner
---
.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 6 +++---
.../python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt | 2 +-
.../python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt | 2 +-
.../python_CoGBK_Dataflow_Flink_Batch_10kB.txt | 2 +-
4 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml
b/.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml
index e00a22b3eee..fcbfbd0dce2 100644
--- a/.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml
+++ b/.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml
@@ -109,7 +109,7 @@ jobs:
arguments: |
--info \
-PloadTest.mainClass=apache_beam.testing.load_tests.co_group_by_key_test \
- -Prunner=FlinkRunner \
+ -Prunner=PortableRunner \
'-PloadTest.args=${{
env.beam_LoadTests_Python_CoGBK_Flink_Batch_test_arguments_1 }}
--job_name=load-tests-python-flink-batch-cogbk-1-${{
steps.datetime.outputs.datetime }}' \
- name: run CoGBK 2GB of 100B records with multiple keys
uses: ./.github/actions/gradle-command-self-hosted-action
@@ -118,7 +118,7 @@ jobs:
arguments: |
--info \
-PloadTest.mainClass=apache_beam.testing.load_tests.co_group_by_key_test \
- -Prunner=FlinkRunner \
+ -Prunner=PortableRunner \
'-PloadTest.args=${{
env.beam_LoadTests_Python_CoGBK_Flink_Batch_test_arguments_2 }}
--job_name=load-tests-python-flink-batch-cogbk-2-${{
steps.datetime.outputs.datetime }}' \
- name: run CoGBK reiterate 4 times 10kB values
uses: ./.github/actions/gradle-command-self-hosted-action
@@ -127,7 +127,7 @@ jobs:
arguments: |
--info \
-PloadTest.mainClass=apache_beam.testing.load_tests.co_group_by_key_test \
- -Prunner=FlinkRunner \
+ -Prunner=PortableRunner \
'-PloadTest.args=${{
env.beam_LoadTests_Python_CoGBK_Flink_Batch_test_arguments_2 }}
--job_name=load-tests-python-flink-batch-cogbk-3-${{
steps.datetime.outputs.datetime }}' \
- name: Teardown Flink
if: always()
diff --git
a/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt
b/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt
index 2530d777c77..163842d7e2b 100644
---
a/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt
+++
b/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Multiple_Keys.txt
@@ -23,7 +23,7 @@
--co_input_options=''{\\"num_records\\":2000000,\\"key_size\\":10,\\"value_size\\":90,\\"num_hot_keys\\":5,\\"hot_key_fraction\\":1}''
--iterations=1
--parallelism=5
---runner=FlinkRunner
+--runner=PortableRunner
--job_endpoint=localhost:8099
--environment_type=DOCKER
--environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_python3.9_sdk:latest
diff --git
a/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt
b/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt
index dbf9d86d805..b704fa057be 100644
---
a/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt
+++
b/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_100b_Single_Key.txt
@@ -23,7 +23,7 @@
--co_input_options=''{\\"num_records\\":2000000,\\"key_size\\":10,\\"value_size\\":90,\\"num_hot_keys\\":1000,\\"hot_key_fraction\\":1}''
--iterations=1
--parallelism=5
---runner=FlinkRunner
+--runner=PortableRunner
--job_endpoint=localhost:8099
--environment_type=DOCKER
--environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_python3.9_sdk:latest
diff --git
a/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_10kB.txt
b/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_10kB.txt
index 02612dbbf62..d0a4c73b728 100644
---
a/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_10kB.txt
+++
b/.github/workflows/load-tests-pipeline-options/python_CoGBK_Dataflow_Flink_Batch_10kB.txt
@@ -23,7 +23,7 @@
--co_input_options=''{\\"num_records\\":2000000,\\"key_size\\":10,\\"value_size\\":90,\\"num_hot_keys\\":1000,\\"hot_key_fraction\\":1}''
--iterations=4
--parallelism=5
---runner=FlinkRunner
+--runner=PortableRunner
--job_endpoint=localhost:8099
--environment_type=DOCKER
--environment_config=gcr.io/apache-beam-testing/beam-sdk/beam_python3.9_sdk:latest
