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