[
https://issues.apache.org/jira/browse/FLINK-21190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284745#comment-17284745
]
Matthias edited comment on FLINK-21190 at 2/28/21, 4:07 PM:
------------------------------------------------------------
The current REST response has the following schema:
{code:javascript}
{
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo",
"properties" : {
"all-exceptions" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:ExecutionExceptionInfo",
"properties" : {
"exception" : {
"type" : "string"
},
"location" : {
"type" : "string"
},
"task" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
}
}
}
},
"root-exception" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
},
"truncated" : {
"type" : "boolean"
}
}
} {code}
I propose to extend the response above by adding a field {{exception-history}}:
{code:javascript}
{
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo",
"properties" : {
"all-exceptions" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:ExecutionExceptionInfo",
"properties" : {
"exception" : {
"type" : "string"
},
"location" : {
"type" : "string"
},
"task" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
}
}
}
},
"root-exception" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
},
"truncated" : {
"type" : "boolean"
},
"exception-history" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:JobExceptionHistoryEntry",
"properties" : {
"all-exceptions" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:ExecutionExceptionInfo",
"properties" : {
"exception" : {
"type" : "string"
},
"location" : {
"type" : "string"
},
"task" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
}
}
}
},
"root-exception" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
},
"truncated" : {
"type" : "boolean"
}
}
}
}
}
}
{code}
A new field {{exception-history}} is added that contains an array of
{{JobExceptionHistoryEntry}} items. {{JobExceptionHistoryEntry}} differs from
the already used {{JobExceptionsInfo}} that it does not have
{{exception-history}} as a field.
was (Author: mapohl):
The current REST response has the following schema:
{code:javascript}
{
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo",
"properties" : {
"all-exceptions" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:ExecutionExceptionInfo",
"properties" : {
"exception" : {
"type" : "string"
},
"location" : {
"type" : "string"
},
"task" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
}
}
}
},
"root-exception" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
},
"truncated" : {
"type" : "boolean"
}
}
} {code}
I propose to extend the response above by adding a field {{failure-history}}:
{code:javascript}
{
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo",
"properties" : {
"all-exceptions" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:ExecutionExceptionInfo",
"properties" : {
"exception" : {
"type" : "string"
},
"location" : {
"type" : "string"
},
"task" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
}
}
}
},
"root-exception" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
},
"truncated" : {
"type" : "boolean"
},
"exception-history" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionHistoryEntry",
"properties" : {
"all-exceptions" : {
"type" : "array",
"items" : {
"type" : "object",
"id" :
"urn:jsonschema:org:apache:flink:runtime:rest:messages:JobExceptionsInfo:ExecutionExceptionInfo",
"properties" : {
"exception" : {
"type" : "string"
},
"location" : {
"type" : "string"
},
"task" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
}
}
}
},
"root-exception" : {
"type" : "string"
},
"timestamp" : {
"type" : "integer"
},
"truncated" : {
"type" : "boolean"
}
}
}
}
}
}
{code}
A new field {{exception-history}} is added that contains an array of
{{JobExceptionHistoryEntry}} items. {{JobExceptionHistoryEntry}} differs from
the already used {{JobExceptionsInfo}} in that it does not have
{{exception-history}} as field.
> Expose extended exception history through REST handler and adapt UI
> accordingly
> -------------------------------------------------------------------------------
>
> Key: FLINK-21190
> URL: https://issues.apache.org/jira/browse/FLINK-21190
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Web Frontend
> Reporter: Matthias
> Assignee: Matthias
> Priority: Major
>
> A first idea of a UI change was proposed by [~vthinkxie] in the parent task:
> !https://issues.apache.org/jira/secure/attachment/13019553/13019553_%E6%88%AA%E5%B1%8F2021-01-28+%E4%B8%8B%E5%8D%884.47.46.png|width=476,height=245!
> The {{JobExceptionsHandler}} response should be extended introducing a new
> (deprecated) field {{otherFailures}}. This way we avoid breaking the API.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
