This commit is contained in:
huiruan 2023-06-04 23:55:03 +08:00
parent 841982bc1f
commit 18c9de2efe
2 changed files with 2 additions and 2 deletions

View File

@ -92,7 +92,7 @@ public class FlushTableProcedure extends AbstractStateMachineTableProcedure<Flus
default:
throw new UnsupportedOperationException("unhandled state=" + state);
}
} catch (IOException e) {
} catch (Exception e) {
setFailure("master-flush-table", e);
}
return Flow.HAS_MORE_STATE;

View File

@ -53,7 +53,7 @@ public class TestFlushTableProcedure extends TestFlushTableProcedureBase {
MasterProcedureEnv env = procExec.getEnvironment();
FlushTableProcedure proc = new FlushTableProcedure(env, TABLE_NAME);
long procId = procExec.submitProcedure(proc);
TEST_UTIL.waitFor(1000, () -> proc.getState().getNumber() > 1);
TEST_UTIL.waitFor(5000, 1000, () -> proc.getState().getNumber() > 1);
TEST_UTIL.getHBaseCluster().killMaster(master.getServerName());
TEST_UTIL.getHBaseCluster().waitForMasterToStop(master.getServerName(), 30000);