diff --git a/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java b/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java index 6445c95..d23baf1 100644 --- a/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java +++ b/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java @@ -263,6 +263,9 @@ private void launchApp(String appName, String queue, int amMB, String storm_zip_ vargs.add(env.get("JAVA_HOME") + "/bin/java"); else vargs.add("java"); + if (null != _stormConf.get("master.childopts")) { + vargs.add((String) _stormConf.get("master.childopts")); + } vargs.add("-Dstorm.home=./storm/" + stormHomeInZip + "/"); vargs.add("-Dlogfile.name=" + ApplicationConstants.LOG_DIR_EXPANSION_VAR + "/master.log"); //vargs.add("-verbose:class");