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

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Duplicate
• Fix Version/s: Not applicable
• Component/s: runner-flink
• Labels: portability-flink
• Assignee: Kyle Weaver
• Reporter: Kyle Weaver
• Created: 29/Jan/20 01:22
• Updated: 16/May/20 13:31
• Resolved: 11/May/20 22:18

Description

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'

Issue Links

• duplicates: BEAM-9600 Implement GetJobMetrics in Flink uber jar job server
• relates to: BEAM-9600 Implement GetJobMetrics in Flink uber jar job server
• links to: GitHub Pull Request #11213