yazgoo created FLINK-16221:
------------------------------
Summary: Execution::transitionState() should log an error when
error parameter is not null
Key: FLINK-16221
URL: https://issues.apache.org/jira/browse/FLINK-16221
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Affects Versions: 1.10.0, 1.9.2
Reporter: yazgoo
Attachments: info_to_error.patch
When execution state transitions with an error, an INFO is logged n
Execution::transitionState().
I think an ERROR should be logged.
This is especially usefull when states transitions to failing, to be able to
retrieve the error causing the failure.
So:
|LOG.error("{} ({}) switched from {} to {}.",
getVertex().getTaskNameWithSubtaskIndex(), getAttemptId(), currentState,
targetState, error);|
should become
|LOG.info("{} ({}) switched from {} to {}.",
getVertex().getTaskNameWithSubtaskIndex(), getAttemptId(), currentState,
targetState, error);|
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
