tillrohrmann commented on a change in pull request #13265:
URL: https://github.com/apache/flink/pull/13265#discussion_r478863140
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java
##########
@@ -36,16 +36,20 @@
*/
class UnsafeMemoryBudget {
private static final int MAX_SLEEPS = 11; // 2^11 - 1 = (2 x 1024) - 1
ms ~ 2 s total sleep duration
- private static final int MAX_SLEEPS_VERIFY_EMPTY = 17; // 2^17 - 1 =
(128 x 1024) - 1 ms ~ 2 min total sleep duration
+ static final int MAX_SLEEPS_VERIFY_EMPTY_FOR_TESTS = 10; // 2^10 - 1 =
(1 x 1024) - 1 ms ~ 1 s total sleep duration
Review comment:
Testing code should not be contained in production code.
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
##########
@@ -89,12 +89,14 @@
*
* @param memorySize The total size of the off-heap memory to be
managed by this memory manager.
* @param pageSize The size of the pages handed out by the memory
manager.
+ * @param verifyEmptyWaitGcMaxSleeps defines how long to wait for GC of
all allocated memory to check for memory leaks,
+ * see also {@link
UnsafeMemoryBudget}.
Review comment:
Hmm, the description says that it is the time to wait for GC but isn't
is the number of exponential retries?
----------------------------------------------------------------
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
