Dan Bress created FLINK-6206:
--------------------------------
Summary: As an Engineer, I want task state transition log to be
warn/error for FAILURE scenarios
Key: FLINK-6206
URL: https://issues.apache.org/jira/browse/FLINK-6206
Project: Flink
Issue Type: Improvement
Components: Core
Affects Versions: 1.2.0
Reporter: Dan Bress
Priority: Critical
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
{code}
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;
}
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
