|
@@ -1728,10 +1728,12 @@ public class DataNode extends ReconfigurableBase
|
|
LOG.warn("Exception shutting down DataNode", e);
|
|
LOG.warn("Exception shutting down DataNode", e);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- try {
|
|
|
|
- httpServer.close();
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- LOG.warn("Exception shutting down DataNode HttpServer", e);
|
|
|
|
|
|
+ if (httpServer != null) {
|
|
|
|
+ try {
|
|
|
|
+ httpServer.close();
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ LOG.warn("Exception shutting down DataNode HttpServer", e);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
if (pauseMonitor != null) {
|
|
if (pauseMonitor != null) {
|