You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by la...@apache.org on 2023/10/13 10:50:13 UTC

[druid] branch master updated: Fixing the flaky tests. (#15142)

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 <ka...@gmail.com>
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: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org