[jira] [Updated] (BEAM-9600) Implement GetJobMetrics in Flink uber jar job server
[ https://issues.apache.org/jira/browse/BEAM-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-9600: -- Labels: portability-flink (was: portability-flink portability-spark) > Implement GetJobMetrics in Flink uber jar job server > > > Key: BEAM-9600 > URL: https://issues.apache.org/jira/browse/BEAM-9600 > Project: Beam > Issue Type: New Feature > Components: runner-flink >Reporter: Kyle Weaver >Assignee: Kyle Weaver >Priority: Major > Labels: portability-flink > Time Spent: 10m > Remaining Estimate: 0h > > 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 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (BEAM-9600) Implement GetJobMetrics in Flink uber jar job server
[ https://issues.apache.org/jira/browse/BEAM-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-9600: -- Component/s: (was: runner-spark) > Implement GetJobMetrics in Flink uber jar job server > > > Key: BEAM-9600 > URL: https://issues.apache.org/jira/browse/BEAM-9600 > Project: Beam > Issue Type: New Feature > Components: runner-flink >Reporter: Kyle Weaver >Assignee: Kyle Weaver >Priority: Major > Labels: portability-flink, portability-spark > Time Spent: 10m > Remaining Estimate: 0h > > 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 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (BEAM-9600) Implement GetJobMetrics in Flink uber jar job server
[ https://issues.apache.org/jira/browse/BEAM-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-9600: -- Summary: Implement GetJobMetrics in Flink uber jar job server (was: Implement GetJobMetrics in Flink or Spark uber jar job server) > Implement GetJobMetrics in Flink uber jar job server > > > Key: BEAM-9600 > URL: https://issues.apache.org/jira/browse/BEAM-9600 > Project: Beam > Issue Type: New Feature > Components: runner-flink, runner-spark >Reporter: Kyle Weaver >Assignee: Kyle Weaver >Priority: Major > Labels: portability-flink, portability-spark > Time Spent: 10m > Remaining Estimate: 0h > > 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 -- This message was sent by Atlassian Jira (v8.3.4#803005)
