YARN-5462. TestNodeStatusUpdater.testNodeStatusUpdaterRetryAndNMShutdown fails intermittently. Contributed by Eric Badger
(cherry picked from commit db646540f0
)
This commit is contained in:
parent
9d62caa440
commit
1ea03411c2
|
@ -561,6 +561,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;
|
||||||
|
@ -1755,6 +1757,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