[
https://issues.apache.org/jira/browse/TWILL-214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
imad updated TWILL-214:
-----------------------
Description:
i want assign some runner on some host ,but when i change RelaxLocality is
false,it was cant assign any container , is more config not swith when i change
RelaxLocality?
String requestId = amClient.addContainerRequest(capability,
newContainers)
.addHosts(hosts)
.addRacks(racks)
.setPriority(0)
.setRelaxLocality(false)
.apply();
next is my app:
@Override
public TwillSpecification configure() {
return TwillSpecification.Builder.with()
.setName("presto")
.withRunnable()
.add("master", new PrestoRunnable(), master).noLocalFiles()
.add("slave", new PrestoRunnable(), slave).noLocalFiles()
.withPlacementPolicy()
.add(Hosts.of("10.129.64.11"), "master")
// .add(Hosts.of(nodeReports.get(1).getHttpAddress()), "slave")
.add(TwillSpecification.PlacementPolicy.Type.DISTRIBUTED, "slave")
.withOrder().begin("master").nextWhenStarted("slave")
.build();
}
}
was:i want assign some runner on some host ,but when i change RelaxLocality
is false,it was cant assign any container , is more config not swith when i
change RelaxLocality?
> RelaxLocality no response
> --------------------------
>
> Key: TWILL-214
> URL: https://issues.apache.org/jira/browse/TWILL-214
> Project: Apache Twill
> Issue Type: Bug
> Environment: hadoop2.6.0-cdh5.8.0
> Reporter: imad
>
> i want assign some runner on some host ,but when i change RelaxLocality is
> false,it was cant assign any container , is more config not swith when i
> change RelaxLocality?
> String requestId = amClient.addContainerRequest(capability,
> newContainers)
> .addHosts(hosts)
> .addRacks(racks)
> .setPriority(0)
> .setRelaxLocality(false)
> .apply();
> next is my app:
> @Override
> public TwillSpecification configure() {
> return TwillSpecification.Builder.with()
> .setName("presto")
> .withRunnable()
> .add("master", new PrestoRunnable(), master).noLocalFiles()
> .add("slave", new PrestoRunnable(), slave).noLocalFiles()
> .withPlacementPolicy()
> .add(Hosts.of("10.129.64.11"), "master")
> // .add(Hosts.of(nodeReports.get(1).getHttpAddress()), "slave")
> .add(TwillSpecification.PlacementPolicy.Type.DISTRIBUTED, "slave")
> .withOrder().begin("master").nextWhenStarted("slave")
> .build();
> }
> }
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
