Skip to content

Commit 85ddd93

Browse files
Fix EQL double invoking listener
We need to break out early here, otherwise we double resolve the listener in the following code potentially.
1 parent eee890a commit 85ddd93

File tree

1 file changed

+1
-0
lines changed
  • x-pack/plugin/eql/src/main/java/org/elasticsearch/xpack/eql/execution/sequence

1 file changed

+1
-0
lines changed

x-pack/plugin/eql/src/main/java/org/elasticsearch/xpack/eql/execution/sequence/TumblingWindow.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,6 +171,7 @@ public void execute(ActionListener<Payload> listener) {
171171
private void tumbleWindow(int currentStage, ActionListener<Payload> listener) {
172172
if (allowPartialSequenceResults == false && shardFailures.isEmpty() == false) {
173173
doPayload(listener);
174+
return;
174175
}
175176
if (currentStage > matcher.firstPositiveStage && matcher.hasCandidates() == false) {
176177
if (restartWindowFromTailQuery) {

0 commit comments

Comments
 (0)