flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject [1/3] flink git commit: [streaming] Logging update for checkpointed streaming topologies
Date Fri, 12 Jun 2015 08:06:01 GMT
Repository: flink
Updated Branches:
  refs/heads/release-0.9 5993e28f3 -> ce3bc9c0b


[streaming] Logging update for checkpointed streaming topologies

Also adding a log message when delaying the retry of the execution graph.

Closes #819


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6380b95a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6380b95a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6380b95a

Branch: refs/heads/release-0.9
Commit: 6380b95a338e1bc717ef7cebd6352da7bbd5d918
Parents: 5993e28
Author: mbalassi <mbalassi@apache.org>
Authored: Wed Jun 10 14:46:11 2015 +0200
Committer: mbalassi <mbalassi@apache.org>
Committed: Fri Jun 12 10:05:12 2015 +0200

----------------------------------------------------------------------
 .../org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java | 1 -
 .../org/apache/flink/runtime/executiongraph/ExecutionGraph.java    | 1 +
 .../java/org/apache/flink/streaming/runtime/tasks/StreamTask.java  | 2 +-
 3 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/6380b95a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
index b52e732..424a9ed 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
@@ -60,7 +60,6 @@ public class CheckpointCoordinator {
 	/** The number of recent checkpoints whose IDs are remembered */
 	private static final int NUM_GHOST_CHECKPOINT_IDS = 16;
 	
-	
 	/** Coordinator-wide lock to safeguard the checkpoint updates */
 	private final Object lock = new Object();
 	

http://git-wip-us.apache.org/repos/asf/flink/blob/6380b95a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
index 705496d..17eb3f6 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
@@ -710,6 +710,7 @@ public class ExecutionGraph implements Serializable {
 								@Override
 								public Object call() throws Exception {
 									try {
+										LOG.info("Delaying retry of job execution for {} ms ...", delayBeforeRetrying);
 										Thread.sleep(delayBeforeRetrying);
 									}
 									catch(InterruptedException e){

http://git-wip-us.apache.org/repos/asf/flink/blob/6380b95a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
index b55272c..db95dcc 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
@@ -233,7 +233,7 @@ public abstract class StreamTask<OUT, O extends StreamOperator<OUT>>
extends Abs
 		synchronized (checkpointLock) {
 			if (isRunning) {
 				try {
-					LOG.info("Starting checkpoint {} on task {}", checkpointId, getName());
+					LOG.debug("Starting checkpoint {} on task {}", checkpointId, getName());
 					
 					// first draw the state that should go into checkpoint
 					StateHandle<Serializable> state;


Mime
View raw message