diff --git a/processing/src/main/java/io/druid/query/RetryQueryRunner.java b/processing/src/main/java/io/druid/query/RetryQueryRunner.java index e086711abd0..d9f5bffba0c 100644 --- a/processing/src/main/java/io/druid/query/RetryQueryRunner.java +++ b/processing/src/main/java/io/druid/query/RetryQueryRunner.java @@ -95,15 +95,7 @@ public class RetryQueryRunner implements QueryRunner } } - - final Sequence retSeq; - if (listOfSequences.size() == 1) { - retSeq = listOfSequences.get(0); - } else { - retSeq = toolChest.mergeSequencesUnordered(Sequences.simple(listOfSequences)); - } - - return retSeq.toYielder(initValue, accumulator); + return toolChest.mergeSequencesUnordered(Sequences.simple(listOfSequences)).toYielder(initValue, accumulator); } }; }