This is an automated email from the ASF dual-hosted git repository.

lakshsingla pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git


The following commit(s) were added to refs/heads/master by this push:
     new f0a70fe3c45 Fixing the flaky tests. (#15142)
f0a70fe3c45 is described below

commit f0a70fe3c4533c889b6185774f104c0265a0c37e
Author: Karan Kumar <[email protected]>
AuthorDate: Fri Oct 13 16:20:05 2023 +0530

    Fixing the flaky tests. (#15142)
---
 .../test/java/org/apache/druid/msq/exec/MSQSelectTest.java  | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git 
a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
 
b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
index 31ea6437519..30bbb850fbc 100644
--- 
a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
+++ 
b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
@@ -1467,22 +1467,21 @@ public class MSQSelectTest extends MSQTestBase
         );
     // adding result stage counter checks
     if (isPageSizeLimited()) {
-      selectTester = selectTester.setExpectedCountersForStageWorkerChannel(
+      selectTester.setExpectedCountersForStageWorkerChannel(
           CounterSnapshotMatcher
-              .with().rows(2, 0, 2).frames(1, 0, 1),
+              .with().rows(2, 0, 2),
           1, 0, "input0"
       ).setExpectedCountersForStageWorkerChannel(
           CounterSnapshotMatcher
-              .with().rows(2, 0, 2).frames(1, 0, 1),
+              .with().rows(2, 0, 2),
           1, 0, "output"
-      );
-      selectTester = selectTester.setExpectedCountersForStageWorkerChannel(
+      ).setExpectedCountersForStageWorkerChannel(
           CounterSnapshotMatcher
-              .with().rows(0, 2, 0, 4).frames(0, 1, 0, 1),
+              .with().rows(0, 2, 0, 4),
           1, 1, "input0"
       ).setExpectedCountersForStageWorkerChannel(
           CounterSnapshotMatcher
-              .with().rows(0, 2, 0, 4).frames(0, 1, 0, 1),
+              .with().rows(0, 2, 0, 4),
           1, 1, "output"
       );
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to