[GitHub] [beam] boyuanzz commented on pull request #11585: [BEAM-9860] Make job_endpoint required for PortableRunner

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org