dawidwys commented on a change in pull request #17664:
URL: https://github.com/apache/flink/pull/17664#discussion_r742708823
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/throughput/BufferDebloater.java
##########
@@ -50,6 +54,14 @@ public BufferDebloater(
this.lastBufferSize = maxBufferSize;
bufferSizeEMA = new BufferSizeEMA(maxBufferSize, minBufferSize,
numberOfSamples);
+
+ LOG.debug(
Review comment:
Would it make more sense to move the log to the point where we construct
the `BufferDebloater`? Now that we have a debloater per gate I believe it would
make sense to add e.g. the gate index for the debloater?
--
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]
