From aa3d3bf30193fbb7b82a652fbcc1b02d09b312a6 Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Fri, 26 Jul 2024 12:41:27 -0700 Subject: [PATCH] Address static check. --- .../msq/shuffle/output/FutureReadableFrameChannel.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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. } } }