flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [tez] Fix Flink-on-Tez use of pre-allocating MemoryManager
Date Tue, 26 May 2015 14:42:57 GMT
Repository: flink
Updated Branches:
  refs/heads/master 043772244 -> eba6f9a2f


[tez] Fix Flink-on-Tez use of pre-allocating MemoryManager


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eba6f9a2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/eba6f9a2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/eba6f9a2

Branch: refs/heads/master
Commit: eba6f9a2f7bfd15a9adf15d356e699a0143bb5a1
Parents: 0437722
Author: Stephan Ewen <sewen@apache.org>
Authored: Tue May 26 16:41:54 2015 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Tue May 26 16:41:54 2015 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/tez/runtime/TezRuntimeEnvironment.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/eba6f9a2/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezRuntimeEnvironment.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezRuntimeEnvironment.java
b/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezRuntimeEnvironment.java
index 39386e6..4cf855a 100644
--- a/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezRuntimeEnvironment.java
+++ b/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezRuntimeEnvironment.java
@@ -36,7 +36,7 @@ public class TezRuntimeEnvironment {
 	public TezRuntimeEnvironment(long totalMemory) {
 		int pageSize = DEFAULT_PAGE_SIZE;
 		int numSlots = DEFAULT_NUM_SLOTS;
-		this.memoryManager = new DefaultMemoryManager(totalMemory, numSlots, pageSize);
+		this.memoryManager = new DefaultMemoryManager(totalMemory, numSlots, pageSize, true);
 		this.ioManager = new IOManagerAsync();
 	}
 


Mime
View raw message