[FLINK-9504][logging] Change the log-level of checkpoint duration to …

…debug This closes apache#6111.
tongcheng-elong · Aug 6, 2018 · b2a9131 · b2a9131
1 parent a72d91b
commit b2a9131
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 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
@@ -459,7 +459,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));
  }
 
@@ -474,7 +474,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
@@ -643,7 +643,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));
  }
 
@@ -838,7 +838,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/...ksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/...ksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
@@ -1918,14 +1918,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);
  }
@@ -2363,7 +2363,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();