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)