diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/report/ReportPublisher.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/report/ReportPublisher.java index e3910dbda1ae..a5e04aa5b05b 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/report/ReportPublisher.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/report/ReportPublisher.java @@ -71,7 +71,7 @@ public Configuration getConf() { @Override public void run() { publishReport(); - if (!executor.isShutdown() || + if (!executor.isShutdown() && !(context.getState() == DatanodeStates.SHUTDOWN)) { executor.schedule(this, getReportFrequency(), TimeUnit.MILLISECONDS);