boyuanzz commented on pull request #11585: URL: https://github.com/apache/beam/pull/11585#issuecomment-623585130
This PR breaks :sdks:python:test-suites:portable:py2:crossLanguagePortableWordCount and :sdks:python:test-suites:portable:py2:crossLanguagePythonJavaFlink with the same error message: ``` File "apache_beam/pipeline.py", line 525, in run | -- | -- | return self.runner.run_pipeline(self, self._options) | | File "apache_beam/runners/portability/portable_runner.py", line 422, in run_pipeline | | job_service_handle = self.create_job_service(options) | | File "apache_beam/runners/portability/portable_runner.py", line 328, in create_job_service | | server = self.default_job_server(options) | | File "apache_beam/runners/portability/portable_runner.py", line 307, in default_job_server | | 'You must specify a --job_endpoint when using --runner=PortableRunner. ' | | NotImplementedError: You must specify a --job_endpoint when using --runner=PortableRunner. Alternatively, you may specify which portable runner you intend to use, such as --runner=FlinkRunner or --runner=SparkRunner. ``` We should update `sdks/python/apache_beam/examples/wordcount_xlang.py` with the same requirement. File issue here: https://issues.apache.org/jira/browse/BEAM-9875 ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
