Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 07:25:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing the flaky tests. (#15142)

Browse Source
This commit is contained in:
Karan Kumar 2023-10-13 16:20:05 +05:30 committed by GitHub
parent 4deeb7e936
commit f0a70fe3c4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
View File

@ -1467,22 +1467,21 @@ public class MSQSelectTest extends MSQTestBase
); );
// adding result stage counter checks // adding result stage counter checks
if (isPageSizeLimited()) { if (isPageSizeLimited()) {
selectTester = selectTester.setExpectedCountersForStageWorkerChannel( selectTester.setExpectedCountersForStageWorkerChannel(
CounterSnapshotMatcher CounterSnapshotMatcher
.with().rows(2, 0, 2).frames(1, 0, 1), .with().rows(2, 0, 2),
1, 0, "input0" 1, 0, "input0"
).setExpectedCountersForStageWorkerChannel( ).setExpectedCountersForStageWorkerChannel(
CounterSnapshotMatcher CounterSnapshotMatcher
.with().rows(2, 0, 2).frames(1, 0, 1), .with().rows(2, 0, 2),
1, 0, "output" 1, 0, "output"
); ).setExpectedCountersForStageWorkerChannel(
selectTester = selectTester.setExpectedCountersForStageWorkerChannel(
CounterSnapshotMatcher CounterSnapshotMatcher
.with().rows(0, 2, 0, 4).frames(0, 1, 0, 1), .with().rows(0, 2, 0, 4),
1, 1, "input0" 1, 1, "input0"
).setExpectedCountersForStageWorkerChannel( ).setExpectedCountersForStageWorkerChannel(
CounterSnapshotMatcher CounterSnapshotMatcher
.with().rows(0, 2, 0, 4).frames(0, 1, 0, 1), .with().rows(0, 2, 0, 4),
1, 1, "output" 1, 1, "output"
); );
} }