We need to break out early here, otherwise we double resolve the listener in the following code potentially.
@@ -0,0 +1,5 @@
+pr: 124918
+summary: Fix EQL double invoking listener
+area: EQL
+type: bug
+issues: []
@@ -171,6 +171,7 @@ public class TumblingWindow implements Executable {
private void tumbleWindow(int currentStage, ActionListener<Payload> listener) {
if (allowPartialSequenceResults == false && shardFailures.isEmpty() == false) {
doPayload(listener);
+ return;
}
if (currentStage > matcher.firstPositiveStage && matcher.hasCandidates() == false) {
if (restartWindowFromTailQuery) {