apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject incubator-apex-core git commit: APEX-113 #resolve
Date Fri, 11 Sep 2015 17:29:19 GMT
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 <gaurav@datatorrent.com>
Authored: Fri Sep 11 09:39:19 2015 -0700
Committer: Gaurav <gaurav@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");


Mime
View raw message