You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2015/09/11 19:29:19 UTC
incubator-apex-core git commit: APEX-113 #resolve
Repository: incubator-apex-core
Updated Branches:
refs/heads/devel-3 928d36804 -> 4023ce01d
APEX-113 #resolve
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/4023ce01
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/4023ce01
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/4023ce01
Branch: refs/heads/devel-3
Commit: 4023ce01d9bd9b64bf7034e4bfcf591e4409febb
Parents: 928d368
Author: Gaurav <ga...@datatorrent.com>
Authored: Fri Sep 11 09:39:19 2015 -0700
Committer: Gaurav <ga...@datatorrent.com>
Committed: Fri Sep 11 09:39:19 2015 -0700
----------------------------------------------------------------------
engine/src/main/java/com/datatorrent/stram/StramClient.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/4023ce01/engine/src/main/java/com/datatorrent/stram/StramClient.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/StramClient.java b/engine/src/main/java/com/datatorrent/stram/StramClient.java
index db36ef6..700002a 100644
--- a/engine/src/main/java/com/datatorrent/stram/StramClient.java
+++ b/engine/src/main/java/com/datatorrent/stram/StramClient.java
@@ -550,6 +550,9 @@ public class StramClient
if (dag.getMasterJVMOptions() != null) {
vargs.add(dag.getMasterJVMOptions());
}
+ Path tmpDir = new Path(ApplicationConstants.Environment.PWD.$(),
+ YarnConfiguration.DEFAULT_CONTAINER_TEMP_DIR);
+ vargs.add("-Djava.io.tmpdir=" + tmpDir);
vargs.add("-Xmx" + (amMemory * 3 / 4) + "m");
vargs.add("-XX:+HeapDumpOnOutOfMemoryError");
vargs.add("-XX:HeapDumpPath=/tmp/dt-heap-" + appId.getId() + ".bin");