|
@@ -283,10 +283,8 @@ public class TestCapacityScheduler {
|
|
|
Resources.createResource(2 * GB, 1));
|
|
|
|
|
|
// ResourceRequest priorities
|
|
|
- Priority priority_0 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority.create(0);
|
|
|
- Priority priority_1 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority.create(1);
|
|
|
+ Priority priority_0 = Priority.newInstance(0);
|
|
|
+ Priority priority_1 = Priority.newInstance(1);
|
|
|
|
|
|
// Submit an application
|
|
|
Application application_0 = new Application("user_0", "a1", resourceManager);
|
|
@@ -1514,12 +1512,8 @@ public class TestCapacityScheduler {
|
|
|
Resources.createResource(2 * GB, 1));
|
|
|
|
|
|
// ResourceRequest priorities
|
|
|
- Priority priority_0 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(0);
|
|
|
- Priority priority_1 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(1);
|
|
|
+ Priority priority_0 = Priority.newInstance(0);
|
|
|
+ Priority priority_1 = Priority.newInstance(1);
|
|
|
|
|
|
// Submit application_0
|
|
|
Application application_0 =
|
|
@@ -1634,12 +1628,8 @@ public class TestCapacityScheduler {
|
|
|
Resources.createResource(5 * GB, 1));
|
|
|
|
|
|
// ResourceRequest priorities
|
|
|
- Priority priority_0 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(0);
|
|
|
- Priority priority_1 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(1);
|
|
|
+ Priority priority_0 = Priority.newInstance(0);
|
|
|
+ Priority priority_1 = Priority.newInstance(1);
|
|
|
|
|
|
// Submit application_0
|
|
|
Application application_0 =
|
|
@@ -1754,12 +1744,8 @@ public class TestCapacityScheduler {
|
|
|
Resources.createResource(6 * GB, 1));
|
|
|
|
|
|
// ResourceRequest priorities
|
|
|
- Priority priority_0 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(0);
|
|
|
- Priority priority_1 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(1);
|
|
|
+ Priority priority_0 = Priority.newInstance(0);
|
|
|
+ Priority priority_1 = Priority.newInstance(1);
|
|
|
|
|
|
// Submit application_0
|
|
|
Application application_0 =
|
|
@@ -1812,12 +1798,8 @@ public class TestCapacityScheduler {
|
|
|
Resources.createResource(5 * GB, 1));
|
|
|
|
|
|
// ResourceRequest priorities
|
|
|
- Priority priority_0 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(0);
|
|
|
- Priority priority_1 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(1);
|
|
|
+ Priority priority_0 = Priority.newInstance(0);
|
|
|
+ Priority priority_1 = Priority.newInstance(1);
|
|
|
|
|
|
// Submit application_0
|
|
|
Application application_0 =
|
|
@@ -3385,9 +3367,7 @@ public class TestCapacityScheduler {
|
|
|
registerNode(host_0, 1234, 2345, NetworkTopology.DEFAULT_RACK,
|
|
|
Resources.createResource(8 * GB, 4));
|
|
|
// ResourceRequest priorities
|
|
|
- Priority priority_0 =
|
|
|
- org.apache.hadoop.yarn.server.resourcemanager.resource.Priority
|
|
|
- .create(0);
|
|
|
+ Priority priority_0 = Priority.newInstance(0);
|
|
|
|
|
|
// Submit an application
|
|
|
Application application_0 =
|