Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15927

TaskExecutor should treat it as a fatal error is Task cannot be failed

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Runtime / Task
    • Labels:
      None

      Description

      When the TaskManager cannot mark a task as failed, it is only logged as a warning.
      This should instead be treated as a fatal error.

      TaskExecutor line 1419:

      try {
      	task.failExternally(cause);
      } catch (Throwable t) {
      	log.error("Could not fail task {}.", executionAttemptID, t);
      }
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              sewen Stephan Ewen
            • Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated: