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 <[email protected]> Authored: Fri Sep 11 09:39:19 2015 -0700 Committer: Gaurav <[email protected]> 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");
