Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove close method on MSQWarningReportPublisher. (#17071) 

It didn't do anything and also wasn't called.
This commit is contained in:
Gian Merlino 2024-09-16 06:08:36 -07:00 committed by GitHub
parent 4d8015578d
commit 9696f0b37c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 1 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
View File

@ -117,10 +117,4 @@ public class MSQWarningReportLimiterPublisher implements MSQWarningReportPublish
}
delegate.publishException(stageNumber, e);
}
@Override
public void close() throws IOException
{
delegate.close();
}
}

8
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
View File

@ -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;
}

6
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
View File

@ -63,10 +63,4 @@ public class MSQWarningReportSimplePublisher implements MSQWarningReportPublishe
throw new RuntimeException(e2);
}
}
@Override
public void close()
{
}
}