[jira] [Updated] (TWILL-214) RelaxLocality no response
[
https://issues.apache.org/jira/browse/TWILL-214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
imad updated TWILL-214:
---
Affects Version/s: 0.9.0
> RelaxLocality no response
> --
>
> Key: TWILL-214
> URL: https://issues.apache.org/jira/browse/TWILL-214
> Project: Apache Twill
> Issue Type: Bug
> Components: yarn
>Affects Versions: 0.9.0
> 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)
[jira] [Updated] (TWILL-214) RelaxLocality no response
[
https://issues.apache.org/jira/browse/TWILL-214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
imad updated TWILL-214:
---
Component/s: yarn
> RelaxLocality no response
> --
>
> Key: TWILL-214
> URL: https://issues.apache.org/jira/browse/TWILL-214
> Project: Apache Twill
> Issue Type: Bug
> Components: yarn
>Affects Versions: 0.9.0
> 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)
