This commit is contained in:
@@ -103,7 +103,9 @@ public class HdfsTestService {
|
|||||||
|
|
||||||
public void stop() {
|
public void stop() {
|
||||||
LOG.info("HDFS Minicluster service being shut down.");
|
LOG.info("HDFS Minicluster service being shut down.");
|
||||||
miniDfsCluster.shutdown();
|
if (miniDfsCluster != null) {
|
||||||
|
miniDfsCluster.shutdown();
|
||||||
|
}
|
||||||
miniDfsCluster = null;
|
miniDfsCluster = null;
|
||||||
hadoopConf = null;
|
hadoopConf = null;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user