flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [04/10] flink git commit: [FLINK-1973] [jobmanager] Task execution state messages are logged on INFO level, rather than on DEBUG level
Date Tue, 12 May 2015 21:03:15 GMT
[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 <sewen@apache.org>
Authored: Tue May 5 00:26:05 2015 +0200
Committer: Stephan Ewen <sewen@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)


Mime
View raw message