buska88 commented on code in PR #3824:
URL: https://github.com/apache/celeborn/pull/3824#discussion_r3849779218
##########
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ChannelsLimiter.java:
##########
@@ -156,5 +174,75 @@ public void onTrim() {
}
}
+ /**
+ * Resumes {@code ratio} fraction of paused channels that have a
likely-large stuck half-frame
+ * ({@link TransportFrameDecoder#hasLikelyLargeIncompleteFrame()}), each in
frame-drain mode.
+ */
+ @Override
+ public int drainIncompleteFrame(double ratio) {
+ List<Channel> candidates = new ArrayList<>();
+ for (Channel ch : channels) {
+ if (!ch.isActive() || ch.config().isAutoRead()) {
+ continue;
+ }
+ TransportFrameDecoder decoder = frameDecoderOf(ch);
+ if (decoder != null && decoder.hasLikelyLargeIncompleteFrame()) {
+ candidates.add(ch);
+ }
+ }
+
+ if (candidates.isEmpty()) {
+ // Only worth logging when backpressure is actually active; if isPaused
is false there are
+ // no paused channels to scan, so a zero result is expected and
uninteresting.
+ if (isPaused.get()) {
+ logger.info(
Review Comment:
done,lower it to DEBUG.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
