[
https://issues.apache.org/jira/browse/BEAM-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066281#comment-17066281
]
Kyle Weaver commented on BEAM-9214:
-----------------------------------
The issue is obscured because in JobServiceServicer, the `context` arg is
positional, while in local_job_service.py it is a keyword arg [1]. Adding
`context=None` in portable_runner.py [2] should fix it.
[1]
https://github.com/apache/beam/blob/1fc79497ecbba61b450bd5b01d6eed195de57b4e/sdks/python/apache_beam/runners/portability/local_job_service.py#L151
[2]
https://github.com/apache/beam/blob/1fc79497ecbba61b450bd5b01d6eed195de57b4e/sdks/python/apache_beam/runners/portability/portable_runner.py#L491-L492
> TypeError: GetJobMetrics() missing 1 required positional argument: 'context'
> ----------------------------------------------------------------------------
>
> Key: BEAM-9214
> URL: https://issues.apache.org/jira/browse/BEAM-9214
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Reporter: Kyle Weaver
> Assignee: Kyle Weaver
> Priority: Major
> Labels: portability-flink
>
> I've seen this error myself, and had multiple users report it, but I don't
> know what causes it. In this case, it happened when using
> --flink_submit_uber_jar. But the job succeeded when retried.
> INFO:root:Started Flink job as 2d1bf5003307c580900abe6bbe56d9e8
> INFO:root:Job state changed to STOPPED
> INFO:root:Job state changed to RUNNING
> Traceback (most recent call last):
> File "/usr/local/lib/python3.7/runpy.py", line 193, in _run_module_as_main
> "__main__", mod_spec)
> File "/usr/local/lib/python3.7/runpy.py", line 85, in _run_code
> exec(code, run_globals)
> File
> "/usr/local/lib/python3.7/site-packages/apache_beam/examples/wordcount.py",
> line 138, in <module>
> run()
> File
> "/usr/local/lib/python3.7/site-packages/apache_beam/examples/wordcount.py",
> line 124, in run
> query_result = result.metrics().query(empty_lines_filter)
> File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/portability/portable_runner.py",
> line 390, in metrics
> beam_job_api_pb2.GetJobMetricsRequest(job_id=self._job_id))
> TypeError: GetJobMetrics() missing 1 required positional argument: 'context'
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
