String vmArgsTemplate = processTemplate(entity.getConfig(RiakNode.RIAK_VM_ARGS_TEMPLATE_URL));
DynamicTasks.queueIfPossible(newScript(CUSTOMIZING).body.append("true").newTask());
DynamicTasks.queueIfPossible(SshEffectorTasks.put(getRunDir() + "/vm.args")
.contents(Streams.newInputStreamWithContents(vmArgsTemplate))
.machine(getMachine())
<BUG>.summary("sending the vm.args file to the riak node"));
commands.add(sudo("chown riak:riak " + getRunDir() + "/vm.args"));
commands.add(sudo("mv " + getRunDir() + "/vm.args " + getEtcDir()));
commands.add(sudo(format("sed -i -e \"s/127.0.0.1/%s/g\" %s", getPrivateIp(), getAppConfigLocation())));
if (osDetails.isMac())
commands.add("ulimit -n 4096");
DynamicTasks.queueIfPossible(newScript(CUSTOMIZING)</BUG>
.failOnNonZeroResultCode()

String vmArgsTemplate = processTemplate(entity.getConfig(RiakNode.RIAK_VM_ARGS_TEMPLATE_URL));
DynamicTasks.queueIfPossible(newScript(CUSTOMIZING).body.append("true").newTask());
DynamicTasks.queueIfPossible(SshEffectorTasks.put(getRunDir() + "/vm.args")
.contents(Streams.newInputStreamWithContents(vmArgsTemplate))
.machine(getMachine())
.summary("sending the vm.args file to the riak node"));
if (osDetails.isMac())
