diff --git a/processing/src/main/java/io/druid/query/groupby/epinephelinae/GroupByMergingQueryRunnerV2.java b/processing/src/main/java/io/druid/query/groupby/epinephelinae/GroupByMergingQueryRunnerV2.java
index 1be7b4ce048..c2aee4ffa98 100644
--- a/processing/src/main/java/io/druid/query/groupby/epinephelinae/GroupByMergingQueryRunnerV2.java
+++ b/processing/src/main/java/io/druid/query/groupby/epinephelinae/GroupByMergingQueryRunnerV2.java
@@ -205,49 +205,32 @@ public class GroupByMergingQueryRunnerV2 implements QueryRunner
                                 );
                               }
 
-                              final Releaser bufferReleaser = mergeBufferHolder.increment();
-                              try {
-                                final Releaser grouperReleaser = grouperHolder.increment();
-                                try {
-                                  return exec.submit(
-                                      new AbstractPrioritizedCallable<Boolean>(priority)
-                                      {
-                                        @Override
-                                        public Boolean call() throws Exception
-                                        {
-                                          try {
-                                            final Object retVal = input.run(queryForRunners, responseContext)
-                                                                       .accumulate(grouper, accumulator);
+                              return exec.submit(
+                                  new AbstractPrioritizedCallable<Boolean>(priority)
+                                  {
+                                    @Override
+                                    public Boolean call() throws Exception
+                                    {
+                                      try (
+                                          Releaser bufferReleaser = mergeBufferHolder.increment();
+                                          Releaser grouperReleaser = grouperHolder.increment()
+                                      ) {
+                                        final Object retVal = input.run(queryForRunners, responseContext)
+                                                                   .accumulate(grouper, accumulator);
 
-                                            // Return true if OK, false if resources were exhausted.
-                                            return retVal == grouper;
-                                          }
-                                          catch (QueryInterruptedException e) {
-                                            throw e;
-                                          }
-                                          catch (Exception e) {
-                                            log.error(e, "Exception with one of the sequences!");
-                                            throw Throwables.propagate(e);
-                                          }
-                                          finally {
-                                            grouperReleaser.close();
-                                            bufferReleaser.close();
-                                          }
-                                        }
+                                        // Return true if OK, false if resources were exhausted.
+                                        return retVal == grouper;
                                       }
-                                  );
-                                }
-                                catch (Exception e) {
-                                  // Exception caught while submitting the task; release resources.
-                                  grouperReleaser.close();
-                                  throw e;
-                                }
-                              }
-                              catch (Exception e) {
-                                // Exception caught while submitting the task; release resources.
-                                bufferReleaser.close();
-                                throw e;
-                              }
+                                      catch (QueryInterruptedException e) {
+                                        throw e;
+                                      }
+                                      catch (Exception e) {
+                                        log.error(e, "Exception with one of the sequences!");
+                                        throw Throwables.propagate(e);
+                                      }
+                                    }
+                                  }
+                              );
                             }
                           }
                       )