[BEAM-9600] Implement GetJobMetrics in Flink uber jar job server - ASF JIRA

XML

Word

Printable

JSON

Details

Type: New Feature
Status: Resolved
Priority: P2
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 2.22.0
Component/s: runner-flink
Labels:
- portability-flink

Description

Need to move logic from LocalJobServicer to AbstractJobServiceServicer, which it inherits: https://github.com/apache/beam/blob/1fc79497ecbba61b450bd5b01d6eed195de57b4e/sdks/python/apache_beam/runners/portability/local_job_service.py#L151

Attachments

Issue Links

is duplicated by

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

Resolved

is related to

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

Resolved

BEAM-9612 Implement job metrics in Spark uber jar job server

Open

links to

GitHub Pull Request #11214

GitHub Pull Request #11369

Activity

People

Assignee:: Kyle Weaver

Reporter:: Kyle Weaver

Votes:: 0 Vote for this issue

Watchers:: 1 Start watching this issue

Dates

Created:: 25/Mar/20 00:31

Updated:: 16/May/20 14:17

Resolved:: 11/May/20 22:15

Time Tracking

Estimated:

Not Specified

Remaining:

0h

Logged:

1h