[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)