YARN-5462. TestNodeStatusUpdater.testNodeStatusUpdaterRetryAndNMShutdown fails intermittently. Contributed by Eric Badger
(cherry picked from commit db646540f0
)
This commit is contained in:
parent
aca7eea611
commit
c972498b74
|
@ -557,6 +557,8 @@ public class TestNodeStatusUpdater {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void serviceStop() throws Exception {
|
protected void serviceStop() throws Exception {
|
||||||
|
// Make sure that all containers are started before starting shutdown
|
||||||
|
syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
||||||
System.out.println("Called stooppppp");
|
System.out.println("Called stooppppp");
|
||||||
super.serviceStop();
|
super.serviceStop();
|
||||||
isStopped = true;
|
isStopped = true;
|
||||||
|
@ -1624,6 +1626,9 @@ public class TestNodeStatusUpdater {
|
||||||
new File("start_file.txt"), port);
|
new File("start_file.txt"), port);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
// Wait until we start stopping
|
||||||
|
syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
||||||
|
// Wait until we finish stopping
|
||||||
syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue