diff --git a/server/src/main/java/org/apache/druid/discovery/DataServerResponseHandler.java b/server/src/main/java/org/apache/druid/discovery/DataServerResponseHandler.java index 3f91d41d2359..f8961f734d9b 100644 --- a/server/src/main/java/org/apache/druid/discovery/DataServerResponseHandler.java +++ b/server/src/main/java/org/apache/druid/discovery/DataServerResponseHandler.java @@ -260,7 +260,7 @@ private void setupResponseReadFailure(String msg, Throwable th) { fail.set(msg); queue.clear(); - boolean ignored = queue.offer( + queue.offer( InputStreamHolder.fromStream( new InputStream() {