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();
