@@ -223,12 +223,12 @@ public void testTargetIORateChangesWhenSubmittingMergeTasks() throws Exception {
223223 // assert the IO rate decreases, with a floor limit, when there is just a single merge task running
224224 assertThat (newIORate , either (is (MIN_IO_RATE .getBytes ())).or (lessThan (currentIORate )));
225225 } else if (submittedIOThrottledMergeTasks .get () > threadPoolMergeExecutorService .getMaxConcurrentMerges () * 2 ) {
226- // assert the IO rate increases, with a ceiling limit, when there are many merge tasks enqueued
227- assertThat (newIORate , either (is (MAX_IO_RATE .getBytes ())).or (greaterThan (currentIORate )));
228- } else {
229- // assert the IO rate does NOT change when there are a couple of merge tasks enqueued
230- assertThat (newIORate , equalTo (currentIORate ));
231- }
226+ // assert the IO rate increases, with a ceiling limit, when there are many merge tasks enqueued
227+ assertThat (newIORate , either (is (MAX_IO_RATE .getBytes ())).or (greaterThan (currentIORate )));
228+ } else {
229+ // assert the IO rate does NOT change when there are a couple of merge tasks enqueued
230+ assertThat (newIORate , equalTo (currentIORate ));
231+ }
232232 } else {
233233 // assert the IO rate does not change, when the merge task doesn't support IO throttling
234234 assertThat (newIORate , equalTo (currentIORate ));
@@ -377,12 +377,12 @@ private void testIORateAdjustedForSubmittedTasks(
377377 // assert the IO rate decreases, with a floor limit, when there are few merge tasks enqueued
378378 assertThat (newTargetIORateLimit , either (is (MIN_IO_RATE .getBytes ())).or (lessThan (targetIORateLimit .get ())));
379379 } else if (currentlySubmittedMergeTaskCount .get () > threadPoolMergeExecutorService .getMaxConcurrentMerges () * 2 ) {
380- // assert the IO rate increases, with a ceiling limit, when there are many merge tasks enqueued
381- assertThat (newTargetIORateLimit , either (is (MAX_IO_RATE .getBytes ())).or (greaterThan (targetIORateLimit .get ())));
382- } else {
383- // assert the IO rate does change, when there are a couple of merge tasks enqueued
384- assertThat (newTargetIORateLimit , equalTo (targetIORateLimit .get ()));
385- }
380+ // assert the IO rate increases, with a ceiling limit, when there are many merge tasks enqueued
381+ assertThat (newTargetIORateLimit , either (is (MAX_IO_RATE .getBytes ())).or (greaterThan (targetIORateLimit .get ())));
382+ } else {
383+ // assert the IO rate does change, when there are a couple of merge tasks enqueued
384+ assertThat (newTargetIORateLimit , equalTo (targetIORateLimit .get ()));
385+ }
386386 targetIORateLimit .set (newTargetIORateLimit );
387387 } else {
388388 // execute already submitted merge task
0 commit comments