asfgit closed pull request #6111: [FLINK-9504]Change the log level of
checkpoint duration to debug
URL: https://github.com/apache/flink/pull/6111
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
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 a2e49cb179d..28cbfd43bfd 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 @@ private void closeOutStream() {
}
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 @@ private void closeOutStream() {
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 ab91ee175ed..f9266689b05 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 @@ default void logOperationCompleted(CheckpointStreamFactory
streamFactory, long s
@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 @@ private void unregisterAndCloseStreamAndResultExtractor() {
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 52362c172ff..47841d11256 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 @@ private void closeLocalRegistry() {
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 @@ private void closeLocalRegistry() {
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();
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
