[jira] [Commented] (FLINK-14713) Show All Attempts For Vertex SubTask In Rest Api
[
https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083126#comment-17083126
]
lining commented on FLINK-14713:
[~gjy]
> Show All Attempts For Vertex SubTask In Rest Api
>
>
> Key: FLINK-14713
> URL: https://issues.apache.org/jira/browse/FLINK-14713
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / REST
>Reporter: lining
>Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Flink jobs could recovery by failover, but the user couldn't see any
> information about the jobs' failure. There isn't information about the
> historical attempt.
> h3. Proposed Changes
> h4. Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
> * return subtask all attempt and state
> * AccessExecutionVertex add method to returns the prior executions
> * get prior attempts according to
> AccessExecutionVertex.getPriorExecutionAttempts
> * add SubtaskAllExecutionAttemptsDetailsHandler for prior attempt
> * url /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskIndex/attempts
> * response:
> {code:json}
> {
> "attempts" : {
> "type" : "array",
> "items" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskExecutionAttemptDetailsInfo",
> "properties" : {
> "subtask" : {
> "type" : "integer"
> },
> "status" : {
> "type" : "string",
> "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING",
> "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]
> },
> "attempt" : {
> "type" : "integer"
> },
> "host" : {
> "type" : "string"
> },
> "start-time" : {
> "type" : "integer"
> },
> "end-time" : {
> "type" : "integer"
> },
> "duration" : {
> "type" : "integer"
> },
> "metrics" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",
> "properties" : {
> "read-bytes" : {
> "type" : "integer"
> },
> "read-bytes-complete" : {
> "type" : "boolean"
> },
> "write-bytes" : {
> "type" : "integer"
> },
> "write-bytes-complete" : {
> "type" : "boolean"
> },
> "read-records" : {
> "type" : "integer"
> },
> "read-records-complete" : {
> "type" : "boolean"
> },
> "write-records" : {
> "type" : "integer"
> },
> "write-records-complete" : {
> "type" : "boolean"
> }
> }
> }
> }
> }
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-14713) Show All Attempts For Vertex SubTask In Rest Api
[
https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323161#comment-17323161
]
Flink Jira Bot commented on FLINK-14713:
This issue is assigned but has not received an update in 7 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> Show All Attempts For Vertex SubTask In Rest Api
>
>
> Key: FLINK-14713
> URL: https://issues.apache.org/jira/browse/FLINK-14713
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / REST
>Reporter: lining
>Assignee: lining
>Priority: Major
> Labels: pull-request-available, stale-assigned
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> Flink jobs could recovery by failover, but the user couldn't see any
> information about the jobs' failure. There isn't information about the
> historical attempt.
> h3. Proposed Changes
> h4. Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
> * return subtask all attempt and state
> * AccessExecutionVertex add method to returns the prior executions
> * get prior attempts according to
> AccessExecutionVertex.getPriorExecutionAttempts
> * add SubtaskAllExecutionAttemptsDetailsHandler for prior attempt
> * url /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskIndex/attempts
> * response:
> {code:json}
> {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskAllExecutionAttemptsDetailsInfo",
> "properties" : {
> "attempts" : {
> "type" : "array",
> "items" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskExecutionAttemptDetailsInfo",
> "properties" : {
> "subtask" : {
> "type" : "integer"
> },
> "status" : {
> "type" : "string",
> "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING",
> "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]
> },
> "attempt" : {
> "type" : "integer"
> },
> "host" : {
> "type" : "string"
> },
> "start-time" : {
> "type" : "integer"
> },
> "end-time" : {
> "type" : "integer"
> },
> "duration" : {
> "type" : "integer"
> },
> "metrics" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",
> "properties" : {
> "read-bytes" : {
> "type" : "integer"
> },
> "read-bytes-complete" : {
> "type" : "boolean"
> },
> "write-bytes" : {
> "type" : "integer"
> },
> "write-bytes-complete" : {
> "type" : "boolean"
> },
> "read-records" : {
> "type" : "integer"
> },
> "read-records-complete" : {
> "type" : "boolean"
> },
> "write-records" : {
> "type" : "integer"
> },
> "write-records-complete" : {
> "type" : "boolean"
> }
> }
> },
> "taskmanager-id" : {
> "type" : "string"
> },
> "start_time" : {
> "type" : "integer"
> }
> }
> }
> }
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-14713) Show All Attempts For Vertex SubTask In Rest Api
[
https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17333850#comment-17333850
]
Flink Jira Bot commented on FLINK-14713:
This issue was marked "stale-assigned" and has not received an update in 7
days. It is now automatically unassigned. If you are still working on it, you
can assign it to yourself again. Please also give an update about the status of
the work.
> Show All Attempts For Vertex SubTask In Rest Api
>
>
> Key: FLINK-14713
> URL: https://issues.apache.org/jira/browse/FLINK-14713
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / REST
>Reporter: lining
>Assignee: lining
>Priority: Major
> Labels: pull-request-available, stale-assigned
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> Flink jobs could recovery by failover, but the user couldn't see any
> information about the jobs' failure. There isn't information about the
> historical attempt.
> h3. Proposed Changes
> h4. Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
> * return subtask all attempt and state
> * AccessExecutionVertex add method to returns the prior executions
> * get prior attempts according to
> AccessExecutionVertex.getPriorExecutionAttempts
> * add SubtaskAllExecutionAttemptsDetailsHandler for prior attempt
> * url /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskIndex/attempts
> * response:
> {code:json}
> {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskAllExecutionAttemptsDetailsInfo",
> "properties" : {
> "attempts" : {
> "type" : "array",
> "items" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskExecutionAttemptDetailsInfo",
> "properties" : {
> "subtask" : {
> "type" : "integer"
> },
> "status" : {
> "type" : "string",
> "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING",
> "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]
> },
> "attempt" : {
> "type" : "integer"
> },
> "host" : {
> "type" : "string"
> },
> "start-time" : {
> "type" : "integer"
> },
> "end-time" : {
> "type" : "integer"
> },
> "duration" : {
> "type" : "integer"
> },
> "metrics" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",
> "properties" : {
> "read-bytes" : {
> "type" : "integer"
> },
> "read-bytes-complete" : {
> "type" : "boolean"
> },
> "write-bytes" : {
> "type" : "integer"
> },
> "write-bytes-complete" : {
> "type" : "boolean"
> },
> "read-records" : {
> "type" : "integer"
> },
> "read-records-complete" : {
> "type" : "boolean"
> },
> "write-records" : {
> "type" : "integer"
> },
> "write-records-complete" : {
> "type" : "boolean"
> }
> }
> },
> "taskmanager-id" : {
> "type" : "string"
> },
> "start_time" : {
> "type" : "integer"
> }
> }
> }
> }
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-14713) Show All Attempts For Vertex SubTask In Rest Api
[
https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760386#comment-17760386
]
Matthias Pohl commented on FLINK-14713:
---
I closed the PR because of conflicts. The issue is already quite old.
Additionally, I removed the "In Progress" state. I'll leave the issue open in
case someone wants to give it a try once more.
> Show All Attempts For Vertex SubTask In Rest Api
>
>
> Key: FLINK-14713
> URL: https://issues.apache.org/jira/browse/FLINK-14713
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / REST
>Reporter: lining
>Priority: Major
> Labels: auto-unassigned, pull-request-available
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> Flink jobs could recovery by failover, but the user couldn't see any
> information about the jobs' failure. There isn't information about the
> historical attempt.
> h3. Proposed Changes
> h4. Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
> * return subtask all attempt and state
> * AccessExecutionVertex add method to returns the prior executions
> * get prior attempts according to
> AccessExecutionVertex.getPriorExecutionAttempts
> * add SubtaskAllExecutionAttemptsDetailsHandler for prior attempt
> * url /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskIndex/attempts
> * response:
> {code:json}
> {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskAllExecutionAttemptsDetailsInfo",
> "properties" : {
> "attempts" : {
> "type" : "array",
> "items" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskExecutionAttemptDetailsInfo",
> "properties" : {
> "subtask" : {
> "type" : "integer"
> },
> "status" : {
> "type" : "string",
> "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING",
> "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]
> },
> "attempt" : {
> "type" : "integer"
> },
> "host" : {
> "type" : "string"
> },
> "start-time" : {
> "type" : "integer"
> },
> "end-time" : {
> "type" : "integer"
> },
> "duration" : {
> "type" : "integer"
> },
> "metrics" : {
> "type" : "object",
> "id" :
> "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",
> "properties" : {
> "read-bytes" : {
> "type" : "integer"
> },
> "read-bytes-complete" : {
> "type" : "boolean"
> },
> "write-bytes" : {
> "type" : "integer"
> },
> "write-bytes-complete" : {
> "type" : "boolean"
> },
> "read-records" : {
> "type" : "integer"
> },
> "read-records-complete" : {
> "type" : "boolean"
> },
> "write-records" : {
> "type" : "integer"
> },
> "write-records-complete" : {
> "type" : "boolean"
> }
> }
> },
> "taskmanager-id" : {
> "type" : "string"
> },
> "start_time" : {
> "type" : "integer"
> }
> }
> }
> }
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
