in myriad-scheduler/src/main/java/org/apache/myriad/scheduler/ExecutorCommandLineGenerator.java [143:170]
protected List<Protos.CommandInfo.URI> getUris() {
List<Protos.CommandInfo.URI> uris = new ArrayList<>();
if (myriadExecutorConfiguration.getJvmUri().isPresent()) {
final String jvmRemoteUri = myriadExecutorConfiguration.getJvmUri().get();
LOGGER.info("Getting JRE distribution from:" + jvmRemoteUri);
uris.add(Protos.CommandInfo.URI.newBuilder().setValue(jvmRemoteUri).build());
}
if (myriadExecutorConfiguration.getConfigUri().isPresent()) {
String configURI = myriadExecutorConfiguration.getConfigUri().get();
LOGGER.info("Getting Hadoop configuration from: {}", configURI);
uris.add(Protos.CommandInfo.URI.newBuilder().setValue(configURI).build());
} else if (myriadExecutorConfiguration.getNodeManagerUri().isPresent()) {
String configURI = getConfigurationUrl();
LOGGER.info("Getting Hadoop configuration from: {}", configURI);
uris.add(Protos.CommandInfo.URI.newBuilder().setValue(configURI).build());
}
if (myriadExecutorConfiguration.getNodeManagerUri().isPresent()) {
//Both FrameworkUser and FrameworkSuperuser to get all of the directory permissions correct.
if (!(myriadConfiguration.getFrameworkUser().isPresent() && myriadConfiguration.getFrameworkSuperUser().isPresent())) {
LOGGER.warn("Trying to use remote distribution, but frameworkUser and/or frameworkSuperUser not set!" +
"Some features may not work");
}
String nodeManagerUri = myriadExecutorConfiguration.getNodeManagerUri().get();
LOGGER.info("Getting Hadoop distribution from: {}", nodeManagerUri);
uris.add(Protos.CommandInfo.URI.newBuilder().setValue(nodeManagerUri).setExtract(false).build());
}
return uris;
}