[FLINK-6206] Log task state transitions as warn/error for FAILURE scenarios

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Won't Do
• Affects Version/s: 1.2.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Dan Bress
• Created: 28/Mar/17 14:57
• Updated: 24/Jul/23 16:51
• Resolved: 27/Sep/19 10:12

Description

If a task fails due to an exception, I would like that to be logged at a warn or an error level. currently its info

private boolean transitionState(ExecutionState currentState, ExecutionState newState, Throwable cause) {
		if (STATE_UPDATER.compareAndSet(this, currentState, newState)) {
			if (cause == null) {
				LOG.info("{} ({}) switched from {} to {}.", taskNameWithSubtask, executionId, currentState, newState);
			} else {
				LOG.info("{} ({}) switched from {} to {}.", taskNameWithSubtask, executionId, currentState, newState, cause);
			}

			return true;
		} else {
			return false;
		}
	}

Issue Links

• is duplicated by: FLINK-32630 The log level of job failed info should change from INFO to WARN/ERROR if job failed
• links to: GitHub Pull Request #5235
• links to: GitHub Pull Request #5399
• links to: GitHub Pull Request #5399