pnowojski commented on a change in pull request #11899:
URL: https://github.com/apache/flink/pull/11899#discussion_r422946365
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java
##########
@@ -188,4 +198,12 @@ int getNumQueuedRequests() {
};
}
+ private static void logInQueueTime(CheckpointTriggerRequest request) {
+ if (LOG.isDebugEnabled()) {
+ long timeInQueue = request.timestamp -
currentTimeMillis();
+ if (timeInQueue > LOG_TIME_IN_QUEUE_THRESHOLD_MS) {
+ LOG.debug("checkpoint request time in queue:
{}", timeInQueue);
+ }
Review comment:
bump to `100ms` and log as `INFO`? `DEBUG` wouldn't be visible in the
most cases, (for example when users will be reporting to us that checkpoints
are not being triggered).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
