diff --git a/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java b/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java index cbdb01b2f20..e98a3a1d1be 100644 --- a/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java +++ b/test/src/main/java/org/apache/accumulo/test/functional/GracefulShutdownIT.java @@ -232,9 +232,8 @@ public void testGracefulShutdown() throws Exception { control.refreshProcesses(ServerType.COMPACTOR); return control.getProcesses(ServerType.COMPACTOR).isEmpty(); }); - final long numFiles3 = getNumFilesForTable(ctx, tid); - assertTrue(numFiles3 < numFiles2); - assertEquals(1, numFiles3); + Wait.waitFor(() -> getNumFilesForTable(ctx, tid) < numFiles2); + assertEquals(1, getNumFilesForTable(ctx, tid)); getCluster().getConfig().setNumScanServers(1); control.startScanServer(ScanServer.class, 1, GROUP_NAME);