You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/08/03 14:38:32 UTC
[flink] 02/05: [hotfix] Let MemoryManager log start up values
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 928198b9e4aa8d931042af0a03c32bcb37802731
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Thu Aug 2 15:32:42 2018 +0200
[hotfix] Let MemoryManager log start up values
---
.../main/java/org/apache/flink/runtime/memory/MemoryManager.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
index f3bea87..c450880 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
@@ -176,6 +176,15 @@ public class MemoryManager {
default:
throw new IllegalArgumentException("unrecognized memory type: " + memoryType);
}
+
+ LOG.debug("Initialized MemoryManager with total memory size {}, number of slots {}, page size {}, " +
+ "memory type {}, pre allocate memory {} and number of non allocated pages {}.",
+ memorySize,
+ numberOfSlots,
+ pageSize,
+ memoryType,
+ preAllocateMemory,
+ numNonAllocatedPages);
}
// ------------------------------------------------------------------------