Timo Theusner created FLINK-41396:
-------------------------------------
Summary: Inspect a materialized table's continuous refresh job
Key: FLINK-41396
URL: https://issues.apache.org/jira/browse/FLINK-41396
Project: Flink
Issue Type: Sub-task
Components: Table SQL / API
Reporter: Timo Theusner
Add {{{}MaterializedTable#getRefreshJob(){}}}, returning a {{RefreshJob}} with
job ID, status, cluster info, an optional {{JobClient}} and {{{}await{}}}. Jobs
submitted by other programs are reachable too, through the target and cluster
ID the catalog records.
Proposed Changes
* Add {{@PublicEvolving}} {{RefreshJob}} with {{{}getJobID(){}}},
{{{}getJobStatus(){}}}, {{{}getClusterInfo(){}}}, {{{}getJobClient(){}}},
{{await()}} and {{await(long, TimeUnit)}}
* Add {{{}MaterializedTable#getRefreshJob(){}}}, present for {{CONTINUOUS}}
{{ACTIVATED}} tables, empty for {{FULL}}
* Resolve the job through {{RefreshJobController}} and
{{{}JobRetrievalSupportedPipelineExecutor{}}}, bound to its job ID at call time
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
