This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new b2a9131 [FLINK-9504][logging] Change the log-level of checkpoint duration to debug b2a9131 is described below commit b2a91310e1889116926026480c5e9a5e44c96e54 Author: minwenjun <minwen...@didichuxing.com> AuthorDate: Sat Jun 2 21:05:04 2018 +0800 [FLINK-9504][logging] Change the log-level of checkpoint duration to debug This closes #6111. --- .../org/apache/flink/runtime/state/DefaultOperatorStateBackend.java | 4 ++-- .../org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java | 4 ++-- .../flink/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 dfff50d..d9fc41e 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 @@ -459,7 +459,7 @@ public class DefaultOperatorStateBackend implements OperatorStateBackend { } 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)); } @@ -474,7 +474,7 @@ public class DefaultOperatorStateBackend implements OperatorStateBackend { 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 6d2bfef..bc1e0f5 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 @@ -643,7 +643,7 @@ public class HeapKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { @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)); } @@ -838,7 +838,7 @@ public class HeapKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { 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 f7af354..bd0ddf2 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 @@ -1918,14 +1918,14 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { 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); } @@ -2363,7 +2363,7 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { 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();