diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
index 9a8b3f79f6d2..ffc74077502e 100644
--- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
+++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
@@ -117,10 +117,4 @@ public void publishException(int stageNumber, Throwable e)
     }
     delegate.publishException(stageNumber, e);
   }
-
-  @Override
-  public void close() throws IOException
-  {
-    delegate.close();
-  }
 }
diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
index 9dbb51b65698..882ce4e98a64 100644
--- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
+++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
@@ -19,17 +19,11 @@
 
 package org.apache.druid.msq.indexing.error;
 
-import java.io.Closeable;
-import java.io.IOException;
-
 /**
  * Provides an interface for a worker to publish warnings to an external source.
  * For example, the worker uses this interface to send warnings to the controller.
  */
-public interface MSQWarningReportPublisher extends Closeable
+public interface MSQWarningReportPublisher
 {
   void publishException(int stageNumber, Throwable e);
-
-  @Override
-  void close() throws IOException;
 }
diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
index 1353f4040412..0a7554045daf 100644
--- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
+++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
@@ -63,10 +63,4 @@ public void publishException(int stageNumber, Throwable e)
       throw new RuntimeException(e2);
     }
   }
-
-  @Override
-  public void close()
-  {
-
-  }
 }