From 8368e2e82ad6e0605bfbc4692cde3cc09e431816 Mon Sep 17 00:00:00 2001
From: minwenjun <minwenjun@didichuxing.com>
Date: Sat, 2 Jun 2018 21:05:04 +0800
Subject: [PATCH] change the log level of checkpoint cost to debug

---
 .../flink/runtime/state/DefaultOperatorStateBackend.java    | 4 ++--
 .../flink/runtime/state/heap/HeapKeyedStateBackend.java     | 4 ++--
 .../contrib/streaming/state/RocksDBKeyedStateBackend.java   | 6 +++---
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
index a2e49cb179d7f..28cbfd43bfda7 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
@@ -452,7 +452,7 @@ public SnapshotResult<OperatorStateHandle> performOperation() throws Exception {
 					}
 
 					if (asynchronousSnapshots) {
-						LOG.info("DefaultOperatorStateBackend snapshot ({}, asynchronous part) in thread {} took {} ms.",
+						LOG.debug("DefaultOperatorStateBackend snapshot ({}, asynchronous part) in thread {} took {} ms.",
 							streamFactory, Thread.currentThread(), (System.currentTimeMillis() - asyncStartTime));
 					}
 
@@ -467,7 +467,7 @@ public SnapshotResult<OperatorStateHandle> performOperation() throws Exception {
 			task.run();
 		}
 
-		LOG.info("DefaultOperatorStateBackend snapshot ({}, synchronous part) in thread {} took {} ms.",
+		LOG.debug("DefaultOperatorStateBackend snapshot ({}, synchronous part) in thread {} took {} ms.",
 				streamFactory, Thread.currentThread(), (System.currentTimeMillis() - syncStartTime));
 
 		return task;
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
index ab91ee175ed3c..f9266689b05e3 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
@@ -529,7 +529,7 @@ private class AsyncSnapshotStrategySynchronicityBehavior implements SnapshotStra
 
 		@Override
 		public void logOperationCompleted(CheckpointStreamFactory streamFactory, long startTime) {
-			LOG.info("Heap backend snapshot ({}, asynchronous part) in thread {} took {} ms.",
+			LOG.debug("Heap backend snapshot ({}, asynchronous part) in thread {} took {} ms.",
 				streamFactory, Thread.currentThread(), (System.currentTimeMillis() - startTime));
 		}
 
@@ -717,7 +717,7 @@ protected SnapshotResult<KeyedStateHandle> performOperation() throws Exception {
 
 			finalizeSnapshotBeforeReturnHook(task);
 
-			LOG.info("Heap backend snapshot (" + primaryStreamFactory + ", synchronous part) in thread " +
+			LOG.debug("Heap backend snapshot (" + primaryStreamFactory + ", synchronous part) in thread " +
 				Thread.currentThread() + " took " + (System.currentTimeMillis() - syncStartTime) + " ms.");
 
 			return task;
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
index 52362c172ff2d..47841d112564d 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
@@ -1736,14 +1736,14 @@ public SnapshotResult<KeyedStateHandle> performOperation() throws Exception {
 
 						snapshotOperation.writeDBSnapshot();
 
-						LOG.info("Asynchronous RocksDB snapshot ({}, asynchronous part) in thread {} took {} ms.",
+						LOG.debug("Asynchronous RocksDB snapshot ({}, asynchronous part) in thread {} took {} ms.",
 							primaryStreamFactory, Thread.currentThread(), (System.currentTimeMillis() - startTime));
 
 						return snapshotOperation.getSnapshotResultStateHandle();
 					}
 				};
 
-			LOG.info("Asynchronous RocksDB snapshot ({}, synchronous part) in thread {} took {} ms.",
+			LOG.debug("Asynchronous RocksDB snapshot ({}, synchronous part) in thread {} took {} ms.",
 				primaryStreamFactory, Thread.currentThread(), (System.currentTimeMillis() - startTime));
 			return AsyncStoppableTaskWithCallback.from(ioCallable);
 		}
@@ -2185,7 +2185,7 @@ public SnapshotResult<KeyedStateHandle> performOperation() throws Exception {
 
 			writeDBSnapshot();
 
-			LOG.info("Asynchronous RocksDB snapshot ({}, asynchronous part) in thread {} took {} ms.",
+			LOG.debug("Asynchronous RocksDB snapshot ({}, asynchronous part) in thread {} took {} ms.",
 				checkpointStreamSupplier, Thread.currentThread(), (System.currentTimeMillis() - startTime));
 
 			return getSnapshotResultStateHandle();