Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
On task failures, context would be nice to include extra fields like taskName, location, etc.
Discussion under: https://github.com/apache/flink/pull/22506#discussion_r1195408929
We may need to provide more information about the error to the enrichers, e.g. related task. Such information can be decided only after an error occurs. So maybe a more flexible way is to create a new context for each failure dynamically, i.e. create from failedExecution }} in {{{}handleFailure ().
https://github.com/apache/flink/pull/22506#discussion_r1195539179
Introduce FailureEnricherContextFactory and DummyFailureEnricherContextFactory
https://github.com/apache/flink/pull/22506#discussion_r1197573074