|
@@ -170,8 +170,6 @@ public class ITestS3APrefetchingInputStream extends AbstractS3ACostTest {
|
|
|
}
|
|
|
// Verify that once stream is closed, all memory is freed
|
|
|
verifyStatisticGaugeValue(ioStats, STREAM_READ_ACTIVE_MEMORY_IN_USE, 0);
|
|
|
- assertThatStatisticMaximum(ioStats,
|
|
|
- ACTION_EXECUTOR_ACQUIRED + SUFFIX_MAX).isGreaterThan(0);
|
|
|
}
|
|
|
|
|
|
@Test
|
|
@@ -208,8 +206,6 @@ public class ITestS3APrefetchingInputStream extends AbstractS3ACostTest {
|
|
|
}
|
|
|
verifyStatisticGaugeValue(ioStats, STREAM_READ_BLOCKS_IN_FILE_CACHE, 0);
|
|
|
verifyStatisticGaugeValue(ioStats, STREAM_READ_ACTIVE_MEMORY_IN_USE, 0);
|
|
|
- assertThatStatisticMaximum(ioStats,
|
|
|
- ACTION_EXECUTOR_ACQUIRED + SUFFIX_MAX).isGreaterThan(0);
|
|
|
}
|
|
|
|
|
|
@Test
|