Abacn commented on code in PR #36472:
URL: https://github.com/apache/beam/pull/36472#discussion_r2420249258
##########
.github/workflows/beam_LoadTests_Python_CoGBK_Flink_Batch.yml:
##########
@@ -108,28 +108,31 @@ jobs:
gradle-command: :sdks:python:apache_beam:testing:load_tests:run
arguments: |
--info \
+ -PpythonVersion=3.9 \
-PloadTest.mainClass=apache_beam.testing.load_tests.co_group_by_key_test \
- -Prunner=FlinkRunner \
+ -Prunner=PortableRunner \
Review Comment:
PortableRunner should be correct one, see other workflows:
https://github.com/apache/beam/blob/590ece2cd8e586d063686ce4cae86bc7da5a319a/.github/workflows/beam_LoadTests_Python_Combine_Flink_Batch.yml
these tests work by setting up a DataProc cluster and a portable runner
endpoint that map to DataProc, then submit Beam pipelines to the portable
runner endpoint.
The question is why it runs on direct runner previously when setting this
parameter to "FlinkRunner"
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
