You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/05/12 23:03:15 UTC
[04/10] flink git commit: [FLINK-1973] [jobmanager] Task execution
state messages are logged on INFO level, rather than on DEBUG level
[FLINK-1973] [jobmanager] Task execution state messages are logged on INFO level, rather than on DEBUG level
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ededb6b7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ededb6b7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ededb6b7
Branch: refs/heads/master
Commit: ededb6b74a2d388ff1c54ddf0f2733c65675c9a0
Parents: 9b7f8aa
Author: Stephan Ewen <se...@apache.org>
Authored: Tue May 5 00:26:05 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue May 12 21:35:58 2015 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/executiongraph/Execution.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ededb6b7/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
index 731d70f..742a7c1 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -875,10 +875,8 @@ public class Execution implements Serializable {
if (STATE_UPDATER.compareAndSet(this, currentState, targetState)) {
markTimestamp(targetState);
- if (LOG.isDebugEnabled()) {
- LOG.debug("{} ({}) switched from {} to {}.",
- getVertex().getTaskNameWithSubtaskIndex(), getAttemptId(), currentState, targetState);
- }
+ LOG.info(getVertex().getTaskNameWithSubtaskIndex() + " (" + getAttemptId() + ") switched from "
+ + currentState + " to " + targetState);
// make sure that the state transition completes normally.
// potential errors (in listeners may not affect the main logic)