diff --git a/docs/changelog/124918.yaml b/docs/changelog/124918.yaml new file mode 100644 index 0000000000000..19d3c5a77a3f8 --- /dev/null +++ b/docs/changelog/124918.yaml @@ -0,0 +1,5 @@ +pr: 124918 +summary: Fix EQL double invoking listener +area: EQL +type: bug +issues: [] diff --git a/x-pack/plugin/eql/src/main/java/org/elasticsearch/xpack/eql/execution/sequence/TumblingWindow.java b/x-pack/plugin/eql/src/main/java/org/elasticsearch/xpack/eql/execution/sequence/TumblingWindow.java index fac8788db0f95..6ae414e29b613 100644 --- a/x-pack/plugin/eql/src/main/java/org/elasticsearch/xpack/eql/execution/sequence/TumblingWindow.java +++ b/x-pack/plugin/eql/src/main/java/org/elasticsearch/xpack/eql/execution/sequence/TumblingWindow.java @@ -171,6 +171,7 @@ public void execute(ActionListener listener) { private void tumbleWindow(int currentStage, ActionListener listener) { if (allowPartialSequenceResults == false && shardFailures.isEmpty() == false) { doPayload(listener); + return; } if (currentStage > matcher.firstPositiveStage && matcher.hasCandidates() == false) { if (restartWindowFromTailQuery) {