Skip to content

Commit

Permalink
Fix checkstyle and javac
Browse files Browse the repository at this point in the history
  • Loading branch information
bteke committed Nov 30, 2022
1 parent 4bf5b4c commit 97d477d
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,8 @@ public abstract float divide(
* @param resource resource
* @return returns true if any resource is zero.
*/
public abstract boolean isAnyRequestedResourceZeroOrNegative(Resource available, Resource resource);
public abstract boolean isAnyRequestedResourceZeroOrNegative(
Resource available, Resource resource);

/**
* Get resource <code>r</code>and normalize down using step-factor
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.LeafQueue;
import org.apache.hadoop.yarn.util.resource.DominantResourceCalculator;
import org.apache.hadoop.yarn.util.resource.ResourceUtils;
import org.mockito.Matchers;

import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.argThat;
Expand Down Expand Up @@ -132,10 +131,10 @@ public void testInterQueuePreemptionWithMultipleResourceUnbalancedCase() throws
policy.editSchedule();

// Preemption should happen in Queue a, preempt to Queue b
verify(eventHandler, times(1)).handle(Matchers.argThat(
verify(eventHandler, times(1)).handle(argThat(
new TestProportionalCapacityPreemptionPolicy.IsPreemptionRequestFor(
getAppAttemptId(1))));
verify(eventHandler, never()).handle(Matchers.argThat(
verify(eventHandler, never()).handle(argThat(
new TestProportionalCapacityPreemptionPolicy.IsPreemptionRequestFor(
getAppAttemptId(2))));
}
Expand Down

0 comments on commit 97d477d

Please sign in to comment.