Hello Oscar,

You can use Rest API to fetch the Vertices Id which I felt is mapped to
operator ID( I guess so).

http://localhost:8081/jobs/55770be021a8887278234d97684b9518/

You need to provide the jobid which will provide you list of vertices for
the job graph:

 "vertices": [
    {      "id": "bc764cd8ddf7a0cff126f51c16239658",      "name":
"Source: transactions",
      "maxParallelism": 128,
      "parallelism": 1,
      "status": "RUNNING",
      "start-time": 1712199052155,
      "end-time": -1,
      "duration": 249593,
      "tasks": {
        "CREATED": 0,
        "RUNNING": 1,
        "INITIALIZING": 0,
        "CANCELING": 0,
        "FAILED": 0,
        "SCHEDULED": 0,
        "DEPLOYING": 0,
        "FINISHED": 0,
        "CANCELED": 0,
        "RECONCILING": 0
      },
      "metrics": {
        "read-bytes": 0,
        "read-bytes-complete": true,
        "write-bytes": 32768,
        "write-bytes-complete": true,
        "read-records": 0,
        "read-records-complete": true,
        "write-records": 2170,
        "write-records-complete": true,
        "accumulated-backpressured-time": 0,
        "accumulated-idle-time": 0,
        "accumulated-busy-time": "NaN"
      }
    },

   {      "id": "20ba6b65f97481d5570070de90e4e791",
      "name": "fraud-detector -\u003E Sink: send-alerts",
      "maxParallelism": 128,
      "parallelism": 8,
      "status": "RUNNING",
      "start-time": 1712199052156,
      "end-time": -1,
      "duration": 872494,
      "tasks": {
        "CREATED": 0,
        "RUNNING": 8,
        "INITIALIZING": 0,
        "CANCELING": 0,
        "FAILED": 0,
        "SCHEDULED": 0,
        "DEPLOYING": 0,
        "FINISHED": 0,
        "CANCELED": 0,
        "RECONCILING": 0
      },
      "metrics": {
        "read-bytes": 237863,
        "read-bytes-complete": true,
        "write-bytes": 0,
        "write-bytes-complete": true,
        "read-records": 7207,
        "read-records-complete": true,
        "write-records": 0,
        "write-records-complete": true,
        "accumulated-backpressured-time": 0,
        "accumulated-idle-time": 6337349,
        "accumulated-busy-time": 0
      }
    }

Hope this helps!

Sincerely,
Asimansu Bera


On Wed, Apr 3, 2024 at 7:25 AM Oscar Perez via user <user@flink.apache.org>
wrote:

> Hei,
>
> We are facing an issue with one of the jobs in production where fails to
> map state from one deployment to another. I guess the problem is that we
> failed to set a UID and relies on the default of providing one based on hash
>
> Is it possible to see all operators / UIDs at a glance? What is the best
> way to list all operators and associated UIDs? You guys print that
> programmatically or is it accessible via flink UI?
>
> What is the recommended way to do forensics? I.e. to take the UID and see
> to what operator relates?
>
> Thanks for the tips!
> Oscar
>

Reply via email to