diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/output/FutureReadableFrameChannel.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/output/FutureReadableFrameChannel.java index 02f6efdc12bd..8dcb8786713b 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/output/FutureReadableFrameChannel.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/output/FutureReadableFrameChannel.java @@ -95,17 +95,17 @@ public void close() // have no effect. Guard against this case by checking if the channelFuture has resolved, and if so, close the // channel here. try { - final ReadableFrameChannel channel = FutureUtils.getUncheckedImmediately(channelFuture); + final ReadableFrameChannel theChannel = FutureUtils.getUncheckedImmediately(channelFuture); try { - channel.close(); + theChannel.close(); } catch (Throwable t) { log.noStackTrace().warn(t, "Failed to close channel"); } } catch (Throwable ignored) { - // Some error happened while creating the channel. Suppress it. + // Suppress. } } }