Skip to content

Commit

Permalink
Remove close method on MSQWarningReportPublisher. (apache#17071)
Browse files Browse the repository at this point in the history
It didn't do anything and also wasn't called.
  • Loading branch information
gianm authored Sep 16, 2024
1 parent 4d80155 commit 9696f0b
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 19 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -117,10 +117,4 @@ public void publishException(int stageNumber, Throwable e)
}
delegate.publishException(stageNumber, e);
}

@Override
public void close() throws IOException
{
delegate.close();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Original file line number Diff line number Diff line change
Expand Up @@ -63,10 +63,4 @@ public void publishException(int stageNumber, Throwable e)
throw new RuntimeException(e2);
}
}

@Override
public void close()
{

}
}

0 comments on commit 9696f0b

Please sign in to comment.