[jira] [Resolved] (BEAM-9214) TypeError: GetJobMetrics() missing 1 required positional argument: 'context'

["Kyle Weaver (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kyle Weaver resolved BEAM-9214.
-------------------------------
    Fix Version/s: Not applicable
       Resolution: Duplicate

> 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
>             Fix For: Not applicable
>
>          Time Spent: 1h
>  Remaining Estimate: 0h
>
> 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. (EDIT: User reported job worked when retried; I have no idea why that might happen.)
> 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)