HBASE-13591 Attempt to stabilize TestHBaseFsck
This commit is contained in:
parent
977f867439
commit
2e132db85c
|
@ -607,7 +607,7 @@ public class TestHBaseFsck {
|
|||
}
|
||||
|
||||
/**
|
||||
* This test makes sure that with 5 retries both parallel instances
|
||||
* This test makes sure that with 10 retries both parallel instances
|
||||
* of hbck will be completed successfully.
|
||||
*
|
||||
* @throws Exception
|
||||
|
@ -621,7 +621,10 @@ public class TestHBaseFsck {
|
|||
|
||||
@Override
|
||||
public HBaseFsck call() throws Exception {
|
||||
return doFsck(conf, false);
|
||||
// Increase retry attempts to make sure the non-active hbck doesn't get starved
|
||||
Configuration c = new Configuration(conf);
|
||||
c.setInt("hbase.hbck.lockfile.attempts", 10);
|
||||
return doFsck(c, false);
|
||||
}
|
||||
}
|
||||
service = Executors.newFixedThreadPool(2);
|
||||
|
@ -629,7 +632,7 @@ public class TestHBaseFsck {
|
|||
hbck2 = service.submit(new RunHbck());
|
||||
service.shutdown();
|
||||
//wait for 15 seconds, for both hbck calls finish
|
||||
service.awaitTermination(15, TimeUnit.SECONDS);
|
||||
service.awaitTermination(25, TimeUnit.SECONDS);
|
||||
HBaseFsck h1 = hbck1.get();
|
||||
HBaseFsck h2 = hbck2.get();
|
||||
// Both should be successful
|
||||
|
|
Loading…
Reference in New Issue