Hi rania,
If you means the Job Vertex ID of the JobGraph, you can try this:
http://localhost:8081/jobs/
Best,
Yu Chen
发件人: Zhanghao Chen
发送时间: 2023年11月26日 11:02
收件人: rania duni ; user@flink.apache.org
主题: Re: Operator ids
It is not supported yet. Curious why d
Hi Oscar,
The Operator ID of the SQL job was generated by `StreamingJobGraphGenerator`,
it was releated with the topology of the stream graph.
If you would like to confirm that the problem was caused by the changes of
opearator id or not, please remove --allowNonRestoredState, and you will get
Hello!
I want to get the pending records of a task. What is the best approach to get
the unprocessed records of a task?
Hi rania,
Through the following REST APIs, you can get the vertex metrics(chained
operator).
GET http://localhost:8081/jobs//vertices/
Note that vertex_id can be accessed from GET http://localhost:8081/jobs/
However, there is no interface for getting operator-level metrics.
But I was planning t
Hello again!
I found this metric in the docs *inputQueueSize*, and this is the
description
*"The real size of queued input buffers in bytes. The size for local input
channels is always `0` since the local channel takes records directly from
the output queue". *I did a prom query for this metric. I
Hello,
I'm using Flink 1.18 and have this error, any idea? Works in IDE.
2023-11-24 16:04:47.062 [DEBUG] [jobmanager-io-thread-1]
DefaultJobMasterServiceProcess - Initialization of the JobMasterService for job
abbad350a6a161919104f8e2fe2670b8 under leader id
b5a63392-d3e4-49d8-85d1-52cd3b71bf8
退订
Hi Jintao,
Please send an email to user-unsubscr...@flink.apache.org to unsubscribe
the user mailing list.
Jintao Ma 于2023年11月27日周一 09:24写道：
> 退订
>
