Hi.
Maybe the metric reporter[1] is suitabe for your case.
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/metric_reporters/
unknown unknown 于2022年5月28日周六 12:49写道：
> Thanks Shengkai! Unfortunately, this would require querying status for
> each job continuously. Given v
Thanks Shengkai! Unfortunately, this would require querying status for each
job continuously. Given very few pipelines experience failures and they are
far in-between, I am looking for a push based model vs polling.
Thanks
AK
On Thu, May 26, 2022 at 7:21 PM Shengkai Fang wrote:
> Hi.
>
> I thin
Hi.
I think you can use REST OPEN API to fetch the job status from the
JM periodically to detect whether something happens. Currently REST OPEN
API also supports to fetch the exception list for the specified job[2].
Best,
Shengkai
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/ops
