Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Enable resultset validation of Drill tests #15096

Merged
merged 129 commits into from
Oct 10, 2023
Merged

Enable resultset validation of Drill tests #15096

Show file tree
Hide file tree
Changes from 102 commits
Commits
Show all changes
129 commits
Select commit Hold shift + click to select a range
3df0069
use enum for type + assume to mark disabled
kgyrtkirk Sep 21, 2023
21e6d9e
enable rel logging in debug
kgyrtkirk Sep 21, 2023
6de29b1
some changes
kgyrtkirk Sep 21, 2023
6ce9bbd
use local calcite; enable tests
kgyrtkirk Sep 21, 2023
53ddb34
make some tests pass
kgyrtkirk Sep 22, 2023
431ec6c
possble fix; but different format/etc; need different result cmp
kgyrtkirk Sep 22, 2023
3522ef5
parse results
kgyrtkirk Sep 22, 2023
46bcd62
unsorted
kgyrtkirk Sep 22, 2023
b8c4353
more sophisticated order match
kgyrtkirk Sep 22, 2023
be06612
asd
kgyrtkirk Sep 22, 2023
01ee94c
format
kgyrtkirk Sep 22, 2023
39f713b
crap
kgyrtkirk Sep 22, 2023
41120e2
lead/lag default 1
kgyrtkirk Sep 22, 2023
37ba5e7
add smlTbl
kgyrtkirk Sep 22, 2023
0b7a656
fix a 100 more
kgyrtkirk Sep 22, 2023
e0e1575
remove crappy class
kgyrtkirk Sep 22, 2023
628d4c6
undo comment wrap
kgyrtkirk Sep 22, 2023
baddb89
generate junit4 cases - so they can be ignored
kgyrtkirk Sep 22, 2023
181a067
Revert "generate junit4 cases - so they can be ignored"
kgyrtkirk Sep 22, 2023
af10e12
fix some literal stuff
kgyrtkirk Sep 22, 2023
4e0adb8
fix literal
kgyrtkirk Sep 22, 2023
51fb6a6
cases-crap
kgyrtkirk Sep 25, 2023
52e5f8d
try2
kgyrtkirk Sep 25, 2023
749863d
add indexes/etc
kgyrtkirk Sep 25, 2023
bceebf6
ignore some
kgyrtkirk Sep 25, 2023
3d87a29
updates
kgyrtkirk Sep 22, 2023
66a9050
remove ws; wQT
kgyrtkirk Sep 25, 2023
e92a971
remove unneeded method
kgyrtkirk Sep 25, 2023
2ce1cfb
format things
kgyrtkirk Sep 25, 2023
7af7b9d
cleanup
kgyrtkirk Sep 25, 2023
bfc230d
rename/etc
kgyrtkirk Sep 25, 2023
ac2bf6b
re-add cases
kgyrtkirk Sep 25, 2023
b7e564b
ignore some; change annotation a bit
kgyrtkirk Sep 25, 2023
081a2c6
fix long/date
kgyrtkirk Sep 25, 2023
05ae71f
fixes/ginore
kgyrtkirk Sep 25, 2023
7625b4d
ignoremore
kgyrtkirk Sep 25, 2023
6dd8c0b
a bit beter ts parsing
kgyrtkirk Sep 25, 2023
23dcc3f
fix some more
kgyrtkirk Sep 26, 2023
ce7d1eb
marks
kgyrtkirk Sep 26, 2023
bc492e0
cleanup/remove/etc
kgyrtkirk Sep 26, 2023
73c4f4e
checkstyle
kgyrtkirk Sep 26, 2023
6f82841
checkstyle
kgyrtkirk Sep 26, 2023
741459f
instanceof
kgyrtkirk Sep 26, 2023
5b249fe
fixes/etc
kgyrtkirk Sep 26, 2023
0fe39f8
fix pattern
kgyrtkirk Sep 26, 2023
15e46db
cleanup
kgyrtkirk Sep 26, 2023
7c1e2c7
remove cases.yaml
kgyrtkirk Sep 26, 2023
4f25a0d
fixup literals
kgyrtkirk Sep 26, 2023
fef9a5b
accept better
kgyrtkirk Sep 26, 2023
a0a379a
accept some
kgyrtkirk Sep 26, 2023
2fd3e88
more
kgyrtkirk Sep 26, 2023
623d110
few moerw
kgyrtkirk Sep 26, 2023
f3241c0
ignore some more
kgyrtkirk Sep 26, 2023
100315a
fix/etc few more
kgyrtkirk Sep 26, 2023
972757e
fix/etc few more
kgyrtkirk Sep 26, 2023
59fcc60
all ignored or pass
kgyrtkirk Sep 26, 2023
a502c1d
format; prepare to add DRUID_SUM back
kgyrtkirk Sep 26, 2023
4369275
enable-back/etc
kgyrtkirk Sep 26, 2023
7583003
changemessage
kgyrtkirk Sep 26, 2023
aac17c4
remove some stuff
kgyrtkirk Sep 26, 2023
69dec17
negativeTest
kgyrtkirk Sep 27, 2023
c24d479
negativeTest
kgyrtkirk Sep 27, 2023
1e33c7e
fixup
kgyrtkirk Sep 27, 2023
012bbf7
update apidoc
kgyrtkirk Sep 27, 2023
f1e9b16
Merge remote-tracking branch 'kgyrtkirk/windowing-fixes-negativetest'…
kgyrtkirk Sep 27, 2023
9af0edf
some stuiff
kgyrtkirk Sep 27, 2023
b6ca922
add time parsing; accept tests
kgyrtkirk Sep 28, 2023
ceb7558
remove parseException
kgyrtkirk Sep 28, 2023
c1e96da
sysqtest
kgyrtkirk Oct 2, 2023
9151fc6
retain orig SUM
kgyrtkirk Oct 2, 2023
68959a4
Merge remote-tracking branch 'apache/master' into windowing-fixes
kgyrtkirk Oct 3, 2023
7e2b56f
inputAccessor
kgyrtkirk Oct 3, 2023
8df9ab5
nulls x0
kgyrtkirk Oct 3, 2023
abf5bd6
Revert "nulls x0"
kgyrtkirk Oct 3, 2023
908cc9f
add test
kgyrtkirk Oct 3, 2023
284767a
x
kgyrtkirk Oct 3, 2023
66c287d
removeXYZ
kgyrtkirk Oct 3, 2023
fa85d15
migration pattern
kgyrtkirk Oct 3, 2023
06933a0
step1
kgyrtkirk Oct 3, 2023
b3f1dfa
implement/etc/finish test
kgyrtkirk Oct 3, 2023
f412344
rename test
kgyrtkirk Oct 3, 2023
36667d2
rename
kgyrtkirk Oct 3, 2023
aad8c38
some more stuff
kgyrtkirk Oct 3, 2023
4998e1c
move some stuff outside
kgyrtkirk Oct 3, 2023
4237989
one more
kgyrtkirk Oct 3, 2023
95d1402
more
kgyrtkirk Oct 3, 2023
6e18d01
fix a few more
kgyrtkirk Oct 3, 2023
3360c8c
finish core aggs
kgyrtkirk Oct 3, 2023
ef50c29
Merge remote-tracking branch 'apache/master' into windowing-fixes
kgyrtkirk Oct 4, 2023
cd8fe62
Merge remote-tracking branch 'apache/master' into windowing-fixes
kgyrtkirk Oct 4, 2023
76838d1
w/o typesys modification
kgyrtkirk Oct 5, 2023
362f796
Revert "w/o typesys modification"
kgyrtkirk Oct 5, 2023
fe6c32c
Revert "Revert "w/o typesys modification""
kgyrtkirk Oct 5, 2023
ca8dcdd
undo inputaccessor
kgyrtkirk Oct 5, 2023
c39b628
remove unrelated testcase
kgyrtkirk Oct 5, 2023
52b99e3
cleanup
kgyrtkirk Oct 5, 2023
0bebc12
cleanup
kgyrtkirk Oct 5, 2023
ffec495
cleanup/etc
kgyrtkirk Oct 5, 2023
94cbc6b
remove throws
kgyrtkirk Oct 5, 2023
ee78be5
fix warning
kgyrtkirk Oct 5, 2023
459957e
newline
kgyrtkirk Oct 5, 2023
819705d
dont use org.apache.curator.shaded.com.google.common.primitives.Doubles
kgyrtkirk Oct 5, 2023
0613caf
Merge remote-tracking branch 'apache/master' into windowing-fixes
kgyrtkirk Oct 6, 2023
4ab39b6
fix conflict
kgyrtkirk Oct 6, 2023
6dbffce
messages
kgyrtkirk Oct 6, 2023
ac0b441
address comments; fix huge bug in verify
kgyrtkirk Oct 6, 2023
00479f2
remove approx
kgyrtkirk Oct 6, 2023
c473f01
tries to fix t_alltypes
kgyrtkirk Oct 6, 2023
3804c77
Revert "tries to fix t_alltypes"
kgyrtkirk Oct 6, 2023
454ae36
annotate some more tests
kgyrtkirk Oct 6, 2023
e9aa601
cleanup
kgyrtkirk Oct 6, 2023
2fa47c6
update/ignore all failing
kgyrtkirk Oct 6, 2023
7c23b5e
reorder
kgyrtkirk Oct 6, 2023
7d064b2
rename annotation
kgyrtkirk Oct 6, 2023
3d82b4e
undo annot rename
kgyrtkirk Oct 9, 2023
045f34b
Merge remote-tracking branch 'apache/master' into windowing-fixes
kgyrtkirk Oct 9, 2023
aa8e888
fix after master merge
kgyrtkirk Oct 9, 2023
9f3df59
plus2;minus2;alter1
kgyrtkirk Oct 9, 2023
8f8bed5
move parsing to new method
kgyrtkirk Oct 9, 2023
147811e
first repro of 0 long
kgyrtkirk Oct 9, 2023
b35a9a2
add registry
kgyrtkirk Oct 9, 2023
6438967
all types affected
kgyrtkirk Oct 9, 2023
cdfc3f2
undo windowing changes
kgyrtkirk Oct 9, 2023
73e9c8e
NotYetSupported instead fixme
kgyrtkirk Oct 9, 2023
f0a6a7d
remove logging stuff
kgyrtkirk Oct 9, 2023
80034be
update javadoc
kgyrtkirk Oct 9, 2023
80ee374
Merge remote-tracking branch 'apache/master' into windowing-fixes
kgyrtkirk Oct 9, 2023
8d75371
fixcheckstyle
kgyrtkirk Oct 9, 2023
dcaa67b
undo non-desired test changes
kgyrtkirk Oct 9, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 7 additions & 1 deletion sql/src/main/java/org/apache/druid/sql/calcite/planner/CalciteRulesManager.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -233,7 +233,13 @@ public List<Program> programs(final PlannerContext plannerContext)

boolean isDebug = plannerContext.queryContext().isDebug();
return ImmutableList.of(
Programs.sequence(preProgram, Programs.ofRules(druidConventionRuleSet(plannerContext))),
Programs.sequence(
new LoggingProgram("Start", isDebug),
preProgram,
new LoggingProgram("After preProgram", isDebug),
Programs.ofRules(druidConventionRuleSet(plannerContext)),
new LoggingProgram("After volcano planner program", isDebug)
),
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm guessing you added this for debugging, I suspect you intended to remove before merge.

Programs.sequence(preProgram, Programs.ofRules(bindableConventionRuleSet(plannerContext))),
Programs.sequence(
// currently, adding logging program after every stage for easier debugging
Expand Down
2 changes: 1 addition & 1 deletion sql/src/test/java/org/apache/druid/sql/calcite/BaseCalciteQueryTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1056,7 +1056,7 @@ public Map<String, Object> baseQueryContext()

public void assertResultsEquals(String sql, List<Object[]> expectedResults, List<Object[]> results)
{
for (int i = 0; i < results.size(); i++) {
for (int i = 0; i < Math.min(results.size(), expectedResults.size()); i++) {
kgyrtkirk marked this conversation as resolved.
Show resolved Hide resolved
Assert.assertArrayEquals(
StringUtils.format("result #%d: %s", i + 1, sql),
expectedResults.get(i),
Expand Down
68 changes: 34 additions & 34 deletions sql/src/test/java/org/apache/druid/sql/calcite/CalciteQueryTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@
import org.apache.druid.segment.column.ColumnType;
import org.apache.druid.segment.column.RowSignature;
import org.apache.druid.segment.join.JoinType;
import org.apache.druid.sql.calcite.DecoupledIgnore.Modes;
import org.apache.druid.sql.calcite.NegativeTest.Modes;
import org.apache.druid.sql.calcite.expression.DruidExpression;
import org.apache.druid.sql.calcite.filtration.Filtration;
import org.apache.druid.sql.calcite.planner.Calcites;
Expand Down Expand Up @@ -2687,7 +2687,7 @@ public void testGroupByWithSelectProjections()
);
}

@DecoupledIgnore(mode = Modes.CANNOT_CONVERT)
@NegativeTest(Modes.CANNOT_CONVERT)
@Test
public void testGroupByWithSelectAndOrderByProjections()
{
Expand Down Expand Up @@ -2772,7 +2772,7 @@ public void testTopNWithSelectProjections()
);
}

@DecoupledIgnore(mode = Modes.CANNOT_CONVERT)
@NegativeTest(Modes.CANNOT_CONVERT)
@Test
public void testTopNWithSelectAndOrderByProjections()
{
Expand Down Expand Up @@ -2810,7 +2810,7 @@ public void testTopNWithSelectAndOrderByProjections()
);
}

@DecoupledIgnore
@NegativeTest
@Test
public void testUnionAllQueries()
{
Expand Down Expand Up @@ -2844,7 +2844,7 @@ public void testUnionAllQueries()
);
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testUnionAllQueriesWithLimit()
{
Expand Down Expand Up @@ -2873,7 +2873,7 @@ public void testUnionAllQueriesWithLimit()
);
}

@DecoupledIgnore
@NegativeTest
@Test
public void testUnionAllDifferentTablesWithMapping()
{
Expand Down Expand Up @@ -2917,7 +2917,7 @@ public void testUnionAllDifferentTablesWithMapping()
);
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testJoinUnionAllDifferentTablesWithMapping()
{
Expand Down Expand Up @@ -2981,7 +2981,7 @@ public void testUnionAllTablesColumnCountMismatch()
}
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testUnionAllTablesColumnTypeMismatchFloatLong()
{
Expand Down Expand Up @@ -3029,7 +3029,7 @@ public void testUnionAllTablesColumnTypeMismatchFloatLong()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnionAllTablesColumnTypeMismatchStringLong()
{
Expand All @@ -3047,7 +3047,7 @@ public void testUnionAllTablesColumnTypeMismatchStringLong()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnionAllTablesWhenMappingIsRequired()
{
Expand All @@ -3064,7 +3064,7 @@ public void testUnionAllTablesWhenMappingIsRequired()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnionIsUnplannable()
{
Expand All @@ -3075,7 +3075,7 @@ public void testUnionIsUnplannable()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnionAllTablesWhenCastAndMappingIsRequired()
{
Expand All @@ -3091,7 +3091,7 @@ public void testUnionAllTablesWhenCastAndMappingIsRequired()
);
}

@DecoupledIgnore
@NegativeTest
@Test
public void testUnionAllSameTableTwice()
{
Expand Down Expand Up @@ -3135,7 +3135,7 @@ public void testUnionAllSameTableTwice()
);
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testUnionAllSameTableTwiceWithSameMapping()
{
Expand Down Expand Up @@ -3179,7 +3179,7 @@ public void testUnionAllSameTableTwiceWithSameMapping()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnionAllSameTableTwiceWithDifferentMapping()
{
Expand All @@ -3193,7 +3193,7 @@ public void testUnionAllSameTableTwiceWithDifferentMapping()
"SQL requires union between two tables and column names queried for each table are different Left: [dim1, dim2, m1], Right: [dim2, dim1, m1]."
);
}
@DecoupledIgnore
@NegativeTest
@Test
public void testUnionAllSameTableThreeTimes()
{
Expand Down Expand Up @@ -3298,7 +3298,7 @@ public void testUnionAllThreeTablesColumnCountMismatch3()
}
}

@DecoupledIgnore
@NegativeTest
@Test
public void testUnionAllSameTableThreeTimesWithSameMapping()
{
Expand Down Expand Up @@ -5021,7 +5021,7 @@ public void testSimpleAggregations()
);
}

@DecoupledIgnore(mode = Modes.CANNOT_CONVERT)
@NegativeTest(Modes.CANNOT_CONVERT)
@Test
public void testGroupByWithSortOnPostAggregationDefault()
{
Expand Down Expand Up @@ -5053,7 +5053,7 @@ public void testGroupByWithSortOnPostAggregationDefault()
);
}

@DecoupledIgnore(mode = Modes.CANNOT_CONVERT)
@NegativeTest(Modes.CANNOT_CONVERT)
@Test
public void testGroupByWithSortOnPostAggregationNoTopNConfig()
{
Expand Down Expand Up @@ -5097,7 +5097,7 @@ public void testGroupByWithSortOnPostAggregationNoTopNConfig()
);
}

@DecoupledIgnore(mode = Modes.CANNOT_CONVERT)
@NegativeTest(Modes.CANNOT_CONVERT)
@Test
public void testGroupByWithSortOnPostAggregationNoTopNContext()
{
Expand Down Expand Up @@ -5685,7 +5685,7 @@ public void testCountStarWithNotOfDegenerateFilter()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnplannableQueries()
{
Expand Down Expand Up @@ -5757,7 +5757,7 @@ public void testCountStarWithBoundFilterSimplifyOr()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testUnplannableExactCountDistinctOnSketch()
{
Expand Down Expand Up @@ -6752,7 +6752,7 @@ public void testApproxCountDistinctBuiltin()
);
}

@DecoupledIgnore(mode = Modes.PLAN_MISMATCH)
@NegativeTest(Modes.PLAN_MISMATCH)
@Test
public void testExactCountDistinctWithGroupingAndOtherAggregators()
{
Expand Down Expand Up @@ -6807,7 +6807,7 @@ public void testExactCountDistinctWithGroupingAndOtherAggregators()
);
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testMultipleExactCountDistinctWithGroupingAndOtherAggregatorsUsingJoin()
{
Expand Down Expand Up @@ -7329,7 +7329,7 @@ public void testExactCountDistinctUsingSubquery()
);
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testExactCountDistinctUsingSubqueryOnUnionAllTables()
{
Expand Down Expand Up @@ -7504,7 +7504,7 @@ public void testQueryWithMoreThanMaxNumericInFilter()
);
}

@DecoupledIgnore(mode = Modes.PLAN_MISMATCH)
@NegativeTest(Modes.PLAN_MISMATCH)
@Test
public void testExactCountDistinctUsingSubqueryWithWherePushDown()
{
Expand Down Expand Up @@ -8235,7 +8235,7 @@ public void testGroupAndFilterOnTimeFloorWithTimeZone()
);
}

@DecoupledIgnore(mode = Modes.PLAN_MISMATCH)
@NegativeTest(Modes.PLAN_MISMATCH)
@Test
public void testFilterOnCurrentTimestampWithIntervalArithmetic()
{
Expand Down Expand Up @@ -8283,7 +8283,7 @@ public void testFilterOnCurrentTimestampLosAngeles()
);
}

@DecoupledIgnore(mode = Modes.PLAN_MISMATCH)
@NegativeTest(Modes.PLAN_MISMATCH)
@Test
public void testFilterOnCurrentTimestampOnView()
{
Expand Down Expand Up @@ -10534,7 +10534,7 @@ public void testGroupByTimeAndOtherDimension()
);
}

@DecoupledIgnore(mode = Modes.PLAN_MISMATCH)
@NegativeTest(Modes.PLAN_MISMATCH)
@Test
public void testGroupByTimeFloorAndDimOnGroupByTimeFloorAndDim()
{
Expand Down Expand Up @@ -11983,7 +11983,7 @@ public void testTextcat()
);
}

@DecoupledIgnore
@NegativeTest
@Test
public void testRequireTimeConditionPositive()
{
Expand Down Expand Up @@ -12187,7 +12187,7 @@ public void testRequireTimeConditionSubQueryNegative()
);
}

@DecoupledIgnore(mode = Modes.ERROR_HANDLING)
@NegativeTest(Modes.ERROR_HANDLING)
@Test
public void testRequireTimeConditionSemiJoinNegative()
{
Expand Down Expand Up @@ -14166,7 +14166,7 @@ public void testReturnEmptyRowWhenGroupByIsConvertedToTimeseriesWithMultipleCons
);
}

@DecoupledIgnore(mode = Modes.PLAN_MISMATCH)
@NegativeTest(Modes.PLAN_MISMATCH)
@Test
public void testPlanWithInFilterLessThanInSubQueryThreshold()
{
Expand Down Expand Up @@ -14487,7 +14487,7 @@ public void testComplexDecodeAgg()
)
);
}
@DecoupledIgnore
@NegativeTest
@Test
public void testOrderByAlongWithInternalScanQuery()
{
Expand Down Expand Up @@ -14530,7 +14530,7 @@ public void testOrderByAlongWithInternalScanQuery()
);
}

@DecoupledIgnore(mode = Modes.NOT_ENOUGH_RULES)
@NegativeTest(Modes.NOT_ENOUGH_RULES)
@Test
public void testOrderByAlongWithInternalScanQueryNoDistinct()
{
Expand Down
4 changes: 2 additions & 2 deletions sql/src/test/java/org/apache/druid/sql/calcite/DecoupledPlanningCalciteQueryTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
import com.google.common.collect.ImmutableMap;
import org.apache.druid.query.QueryContexts;
import org.apache.druid.server.security.AuthConfig;
import org.apache.druid.sql.calcite.DecoupledIgnore.DecoupledIgnoreProcessor;
import org.apache.druid.sql.calcite.NegativeTest.NegativeTestProcessor;
import org.apache.druid.sql.calcite.planner.PlannerConfig;
import org.apache.druid.sql.calcite.util.SqlTestFramework;
import org.junit.Rule;
Expand All @@ -31,7 +31,7 @@ public class DecoupledPlanningCalciteQueryTest extends CalciteQueryTest
{

@Rule(order = 0)
public DecoupledIgnoreProcessor decoupledIgnoreProcessor = new DecoupledIgnoreProcessor();
public NegativeTestProcessor decoupledIgnoreProcessor = new NegativeTestProcessor();

private static final ImmutableMap<String, Object> CONTEXT_OVERRIDES = ImmutableMap.of(
PlannerConfig.CTX_NATIVE_QUERY_SQL_PLANNING_MODE, PlannerConfig.NATIVE_QUERY_SQL_PLANNING_MODE_DECOUPLED,
Expand Down
Loading