|
@@ -1057,6 +1057,7 @@ public class DataNode extends Configured
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ this.shouldRun = false;
|
|
|
shutdownPeriodicScanners();
|
|
|
|
|
|
if (infoServer != null) {
|
|
@@ -1070,7 +1071,6 @@ public class DataNode extends Configured
|
|
|
ipcServer.stop();
|
|
|
}
|
|
|
|
|
|
- this.shouldRun = false;
|
|
|
if (dataXceiverServer != null) {
|
|
|
((DataXceiverServer) this.dataXceiverServer.getRunnable()).kill();
|
|
|
this.dataXceiverServer.interrupt();
|