-
Notifications
You must be signed in to change notification settings - Fork 3.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Reduce coordinator logs #17566
Reduce coordinator logs #17566
Conversation
@@ -491,10 +491,9 @@ static List<Interval> filterSkipIntervals(Interval totalInterval, List<Interval> | |||
remainingStart = skipInterval.getEnd(); | |||
} else { | |||
// Ignore this skipInterval | |||
log.warn( | |||
log.debug( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this log doesn't provide much useful info and can remain a debug
new TypeReference<List<DataSegmentChangeRequest>>() | ||
{ | ||
}; | ||
new TypeReference<>() {}; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Java 9+ supports diamond operator with anonymous classes.
Since we have dropped support for Java 8, we can use this syntax here (and in several other places in the code which can be done in a separate PR).
cc: @Akshat-Jain
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Have raised PR: #17567. The PR isn't limited to just anonymous class usages, but rather does it for all usages where explicit type argument was redundant. I don't see an easy way to identify usages only for anonymous classes, and I didn't see any reason why we shouldn't do it for other usages as well, so ended up doing that. Hope that works!
Appreciate your review on the PR, thanks!
log.info("Cancelled [%d] requests queued on server [%s].", queuedSegments.size(), serverId); | ||
if (!queuedSegments.isEmpty()) { | ||
queuedSegments.forEach(holder -> onRequestCompleted(holder, RequestStatus.CANCELLED)); | ||
log.info("Cancelled [%d] requests queued on server[%s].", queuedSegments.size(), serverId); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
log only when non-empty.
server/src/main/java/org/apache/druid/server/coordinator/loading/HttpLoadQueuePeon.java
Outdated
Show resolved
Hide resolved
...r/src/main/java/org/apache/druid/server/compaction/DataSourceCompactibleSegmentIterator.java
Show resolved
Hide resolved
IT failures are unrelated. |
No description provided.