Skip to content

Commit e7295f0

Browse files
ioanatiaioanatia
authored
ES|QL: Remove redundant capability checks in tests (#135695)
1 parent faf18ef commit e7295f0

File tree

11 files changed

+4
-124
lines changed

11 files changed

+4
-124
lines changed

‎x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/ForkIT.java‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@ public class ForkIT extends AbstractEsqlIntegTestCase {
3232

3333
@Before
3434
public void setupIndex() {
35-
assumeTrue("requires FORK capability", EsqlCapabilities.Cap.FORK_V9.isEnabled());
3635
createAndPopulateIndices();
3736
}
3837

‎x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/FuseIT.java‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@ protected Collection<Class<? extends Plugin>> nodePlugins() {
2828

2929
@Before
3030
public void setupIndex() {
31-
assumeTrue("requires FUSE capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
3231
createAndPopulateIndex();
3332
}
3433

‎x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/FuseWithInvalidLicenseIT.java‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,6 @@ protected Collection<Class<? extends Plugin>> nodePlugins() {
3131

3232
@Before
3333
public void setupIndex() {
34-
assumeTrue("requires FUSE capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
3534
var indexName = "test";
3635
var client = client().admin().indices();
3736
var CreateRequest = client.prepareCreate(indexName)

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/analysis/AnalyzerTests.java‎

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2220,8 +2220,6 @@ public void testLookupMatchTypeWrong() {
22202220
}
22212221

22222222
public void testLookupJoinUnknownIndex() {
2223-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
2224-
22252223
String errorMessage = "Unknown index [foobar]";
22262224
IndexResolution missingLookupIndex = IndexResolution.invalid(errorMessage);
22272225

@@ -2250,8 +2248,6 @@ public void testLookupJoinUnknownIndex() {
22502248
}
22512249

22522250
public void testLookupJoinUnknownField() {
2253-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
2254-
22552251
String query = "FROM test | LOOKUP JOIN languages_lookup ON last_name";
22562252
String errorMessage = "1:45: Unknown column [last_name] in right side of join";
22572253

@@ -2273,8 +2269,6 @@ public void testLookupJoinUnknownField() {
22732269
}
22742270

22752271
public void testMultipleLookupJoinsGiveDifferentAttributes() {
2276-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
2277-
22782272
// The field attributes that get contributed by different LOOKUP JOIN commands must have different name ids,
22792273
// even if they have the same names. Otherwise, things like dependency analysis - like in PruneColumns - cannot work based on
22802274
// name ids and shadowing semantics proliferate into all kinds of optimizer code.
@@ -3680,8 +3674,6 @@ public void testForkError() {
36803674
}
36813675

36823676
public void testValidFuse() {
3683-
assumeTrue("requires FUSE capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
3684-
36853677
LogicalPlan plan = analyze("""
36863678
from test metadata _id, _index, _score
36873679
| fork ( where first_name:"foo" )
@@ -3704,8 +3696,6 @@ public void testValidFuse() {
37043696
}
37053697

37063698
public void testFuseError() {
3707-
assumeTrue("requires FUSE capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
3708-
37093699
var e = expectThrows(VerificationException.class, () -> analyze("""
37103700
from test
37113701
| fuse

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/analysis/ParsingTests.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,6 @@ public void testTooBigQuery() {
131131
}
132132

133133
public void testJoinOnConstant() {
134-
assumeTrue("LOOKUP JOIN available as snapshot only", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
135134
assumeTrue(
136135
"requires LOOKUP JOIN ON boolean expression capability",
137136
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -151,15 +150,13 @@ public void testJoinOnConstant() {
151150
}
152151

153152
public void testJoinTwiceOnTheSameField() {
154-
assumeTrue("LOOKUP JOIN available as snapshot only", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
155153
assertEquals(
156154
"1:66: JOIN ON clause does not support multiple fields with the same name, found multiple instances of [languages]",
157155
error("row languages = 1, gender = \"f\" | lookup join test on languages, languages")
158156
);
159157
}
160158

161159
public void testJoinTwiceOnTheSameField_TwoLookups() {
162-
assumeTrue("LOOKUP JOIN available as snapshot only", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
163160
assertEquals(
164161
"1:108: JOIN ON clause does not support multiple fields with the same name, found multiple instances of [gender]",
165162
error("row languages = 1, gender = \"f\" | lookup join test on languages | eval x = 1 | lookup join test on gender, gender")

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/analysis/VerifierTests.java‎

Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -304,12 +304,10 @@ public void testUnsupportedAndMultiTypedFields() {
304304
);
305305
}
306306

307-
if (EsqlCapabilities.Cap.FUSE_V6.isEnabled()) {
308-
assertEquals(
309-
"1:76: cannot use [double] as an input of FUSE. Consider using [DROP double] before FUSE.",
310-
error("from test* METADATA _id, _index, _score | FORK (where true) (where true) | FUSE", analyzer)
311-
);
312-
}
307+
assertEquals(
308+
"1:76: cannot use [double] as an input of FUSE. Consider using [DROP double] before FUSE.",
309+
error("from test* METADATA _id, _index, _score | FORK (where true) (where true) | FUSE", analyzer)
310+
);
313311
}
314312

315313
public void testRoundFunctionInvalidInputs() {
@@ -2230,8 +2228,6 @@ public void testAggregateInRow() {
22302228
}
22312229

22322230
public void testLookupJoinDataTypeMismatch() {
2233-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
2234-
22352231
query("FROM test | EVAL language_code = languages | LOOKUP JOIN languages_lookup ON language_code");
22362232

22372233
assertEquals(
@@ -2241,7 +2237,6 @@ public void testLookupJoinDataTypeMismatch() {
22412237
}
22422238

22432239
public void testLookupJoinExpressionAmbiguousRight() {
2244-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
22452240
assumeTrue(
22462241
"requires LOOKUP JOIN ON boolean expression capability",
22472242
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -2259,7 +2254,6 @@ public void testLookupJoinExpressionAmbiguousRight() {
22592254
}
22602255

22612256
public void testLookupJoinExpressionAmbiguousLeft() {
2262-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
22632257
assumeTrue(
22642258
"requires LOOKUP JOIN ON boolean expression capability",
22652259
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -2277,7 +2271,6 @@ public void testLookupJoinExpressionAmbiguousLeft() {
22772271
}
22782272

22792273
public void testLookupJoinExpressionAmbiguousBoth() {
2280-
assumeTrue("requires LOOKUP JOIN capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
22812274
assumeTrue(
22822275
"requires LOOKUP JOIN ON boolean expression capability",
22832276
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -2558,8 +2551,6 @@ public void testInvalidTBucketCalls() {
25582551
}
25592552

25602553
public void testFuse() {
2561-
assumeTrue("FUSE requires corresponding capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
2562-
25632554
String queryPrefix = "from test metadata _score, _index, _id | fork (where true) (where true)";
25642555

25652556
query(queryPrefix + " | fuse");

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/LogicalPlanOptimizerTests.java‎

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -5349,8 +5349,6 @@ public void testPlanSanityCheck() throws Exception {
53495349
* }</pre>
53505350
*/
53515351
public void testPlanSanityCheckWithBinaryPlans() {
5352-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
5353-
53545352
var plan = optimizedPlan("""
53555353
FROM test
53565354
| RENAME languages AS language_code
@@ -6265,7 +6263,6 @@ public void testInlineStatsWithLookupJoin() {
62656263
| KEEP abbrev, *scalerank
62666264
| LIMIT 5
62676265
""";
6268-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
62696266
if (releaseBuildForInlineStats(query)) {
62706267
return;
62716268
}
@@ -7053,8 +7050,6 @@ public void testLookupStats() {
70537050
* }</pre>
70547051
*/
70557052
public void testLookupJoinPushDownFilterOnJoinKeyWithRename() {
7056-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7057-
70587053
String query = """
70597054
FROM test
70607055
| RENAME languages AS language_code
@@ -7098,8 +7093,6 @@ public void testLookupJoinPushDownFilterOnJoinKeyWithRename() {
70987093
* }</pre>
70997094
*/
71007095
public void testLookupJoinPushDownFilterOnLeftSideField() {
7101-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7102-
71037096
String query = """
71047097
FROM test
71057098
| RENAME languages AS language_code
@@ -7144,8 +7137,6 @@ public void testLookupJoinPushDownFilterOnLeftSideField() {
71447137
* }</pre>
71457138
*/
71467139
public void testLookupJoinPushDownDisabledForLookupField() {
7147-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7148-
71497140
String query = """
71507141
FROM test
71517142
| RENAME languages AS language_code
@@ -7193,8 +7184,6 @@ public void testLookupJoinPushDownDisabledForLookupField() {
71937184
* }</pre>
71947185
*/
71957186
public void testLookupJoinPushDownSeparatedForConjunctionBetweenLeftAndRightField() {
7196-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7197-
71987187
String query = """
71997188
FROM test
72007189
| RENAME languages AS language_code
@@ -7247,8 +7236,6 @@ public void testLookupJoinPushDownSeparatedForConjunctionBetweenLeftAndRightFiel
72477236
* }</pre>
72487237
*/
72497238
public void testLookupJoinPushDownDisabledForDisjunctionBetweenLeftAndRightField() {
7250-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7251-
72527239
String query = """
72537240
FROM test
72547241
| RENAME languages AS language_code
@@ -7301,8 +7288,6 @@ public void testLookupJoinPushDownDisabledForDisjunctionBetweenLeftAndRightField
73017288
* }</pre>
73027289
*/
73037290
public void testLookupJoinKeepNoLookupFields() {
7304-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7305-
73067291
String commandDiscardingFields = randomBoolean() ? "| KEEP languages" : """
73077292
| DROP _meta_field, emp_no, first_name, gender, language_code,
73087293
language_name, last_name, salary, hire_date, job, job.raw, long_noidx
@@ -7346,8 +7331,6 @@ public void testLookupJoinKeepNoLookupFields() {
73467331
* }</pre>
73477332
*/
73487333
public void testMultipleLookupShadowing() {
7349-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7350-
73517334
String query = """
73527335
FROM test
73537336
| EVAL language_code = languages
@@ -8112,8 +8095,6 @@ public void testFunctionNamedParamsAsFunctionArgument1() {
81128095
* }</pre>
81138096
*/
81148097
public void testRedundantSortOnJoin() {
8115-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
8116-
81178098
var plan = optimizedPlan("""
81188099
FROM test
81198100
| SORT languages

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/PhysicalPlanOptimizerTests.java‎

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2915,8 +2915,6 @@ public void testVerifierOnMissingReferences() {
29152915
}
29162916

29172917
public void testVerifierOnMissingReferencesWithBinaryPlans() throws Exception {
2918-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
2919-
29202918
// Do not assert serialization:
29212919
// This will have a LookupJoinExec, which is not serializable because it doesn't leave the coordinator.
29222920
var plan = physicalPlan("""
@@ -7626,8 +7624,6 @@ public void testLookupThenTopN() {
76267624
}
76277625

76287626
public void testLookupJoinFieldLoading() throws Exception {
7629-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7630-
76317627
TestDataSource data = dataSetWithLookupIndices(Map.of("lookup_index", List.of("first_name", "foo", "bar", "baz")));
76327628

76337629
String query = """
@@ -7703,8 +7699,6 @@ public void testLookupJoinFieldLoading() throws Exception {
77037699
}
77047700

77057701
public void testLookupJoinFieldLoadingTwoLookups() throws Exception {
7706-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7707-
77087702
TestDataSource data = dataSetWithLookupIndices(
77097703
Map.of(
77107704
"lookup_index1",
@@ -7756,8 +7750,6 @@ public void testLookupJoinFieldLoadingTwoLookups() throws Exception {
77567750
}
77577751

77587752
public void testLookupJoinFieldLoadingTwoLookupsProjectInBetween() throws Exception {
7759-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7760-
77617753
TestDataSource data = dataSetWithLookupIndices(
77627754
Map.of(
77637755
"lookup_index1",
@@ -7796,8 +7788,6 @@ public void testLookupJoinFieldLoadingTwoLookupsProjectInBetween() throws Except
77967788
}
77977789

77987790
public void testLookupJoinFieldLoadingDropAllFields() throws Exception {
7799-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
7800-
78017791
TestDataSource data = dataSetWithLookupIndices(Map.of("lookup_index", List.of("first_name", "foo", "bar", "baz")));
78027792

78037793
String query = """

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/rules/logical/PushDownJoinPastProjectTests.java‎

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,6 @@ public class PushDownJoinPastProjectTests extends AbstractLogicalPlanOptimizerTe
4545
// | \_EsRelation[languages_lookup][LOOKUP][language_code{f}#24]
4646
// \_EsRelation[languages_lookup][LOOKUP][language_code{f}#26, language_name{f}#27]
4747
public void testMultipleLookups() {
48-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
49-
5048
String query = """
5149
FROM test
5250
| KEEP languages, emp_no
@@ -86,8 +84,6 @@ public void testMultipleLookups() {
8684
// | \_EsRelation[test][_meta_field{f}#17, emp_no{f}#11, first_name{f}#12, ..]
8785
// \_EsRelation[languages_lookup][LOOKUP][language_code{f}#22, language_name{f}#23]
8886
public void testShadowingBeforePushdown() {
89-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
90-
9187
String query = """
9288
FROM test
9389
| RENAME languages AS language_code, last_name AS language_name
@@ -118,8 +114,6 @@ public void testShadowingBeforePushdown() {
118114
// | \_EsRelation[test][_meta_field{f}#20, emp_no{f}#14, first_name{f}#15, ..]
119115
// \_EsRelation[languages_lookup][LOOKUP][language_code{f}#25, language_name{f}#26]
120116
public void testShadowingAfterPushdown() {
121-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
122-
123117
String query = """
124118
FROM test
125119
| EVAL language_name = 2*salary
@@ -179,8 +173,6 @@ public void testShadowingAfterPushdown() {
179173
// | \_EsRelation[test][_meta_field{f}#32, emp_no{f}#26, first_name{f}#27, ..]
180174
// \_EsRelation[test_lookup][LOOKUP][emp_no{f}#37, languages{f}#40, salary{f}#42]
181175
public void testShadowingAfterPushdown2() {
182-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
183-
184176
String query = """
185177
FROM test_lookup
186178
| RENAME emp_no AS x, salary AS salary2
@@ -249,7 +241,6 @@ public void testShadowingAfterPushdown2() {
249241
* \_EsRelation[test_lookup][LOOKUP][emp_no{f}#27, languages{f}#30, salary{f}#32]
250242
*/
251243
public void testShadowingAfterPushdownExpressionJoin() {
252-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
253244
assumeTrue(
254245
"requires LOOKUP JOIN ON boolean expression capability",
255246
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -298,7 +289,6 @@ public void testShadowingAfterPushdownExpressionJoin() {
298289
* \_EsRelation[test_lookup][LOOKUP][emp_no{f}#28, languages{f}#31, salary{f}#33]
299290
*/
300291
public void testShadowingAfterPushdownExpressionJoinKeepOrig() {
301-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
302292
assumeTrue(
303293
"requires LOOKUP JOIN ON boolean expression capability",
304294
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -351,7 +341,6 @@ public void testShadowingAfterPushdownExpressionJoinKeepOrig() {
351341
* \_EsRelation[test_lookup][LOOKUP][emp_no{f}#21, languages{f}#24, salary{f}#26]
352342
*/
353343
public void testShadowingAfterPushdownRenameExpressionJoin() {
354-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
355344
assumeTrue(
356345
"requires LOOKUP JOIN ON boolean expression capability",
357346
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()
@@ -398,7 +387,6 @@ public void testShadowingAfterPushdownRenameExpressionJoin() {
398387
* \_EsRelation[test_lookup][LOOKUP][emp_no{f}#22, languages{f}#25, salary{f}#27]
399388
*/
400389
public void testShadowingAfterPushdownEvalExpressionJoin() {
401-
assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
402390
assumeTrue(
403391
"requires LOOKUP JOIN ON boolean expression capability",
404392
EsqlCapabilities.Cap.LOOKUP_JOIN_ON_BOOLEAN_EXPRESSION.isEnabled()

‎x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/parser/StatementParserTests.java‎

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3214,8 +3214,6 @@ public void testValidFromPattern() {
32143214
}
32153215

32163216
public void testValidJoinPatternFieldJoin() {
3217-
assumeTrue("LOOKUP JOIN requires corresponding capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
3218-
32193217
var basePattern = randomIndexPatterns(without(CROSS_CLUSTER));
32203218
var joinPattern = randomIndexPattern(without(WILDCARD_PATTERN), without(CROSS_CLUSTER), without(INDEX_SELECTOR));
32213219
var numberOfOnFields = randomIntBetween(1, 5);
@@ -3532,8 +3530,6 @@ private String singleExpressionJoinClause() {
35323530
}
35333531

35343532
private void testInvalidJoinPatterns(String onClause) {
3535-
assumeTrue("LOOKUP JOIN requires corresponding capability", EsqlCapabilities.Cap.JOIN_LOOKUP_V12.isEnabled());
3536-
35373533
{
35383534
// wildcard
35393535
var joinPattern = randomIndexPattern(WILDCARD_PATTERN, without(CROSS_CLUSTER), without(INDEX_SELECTOR));
@@ -4218,8 +4214,6 @@ static Alias alias(String name, Expression value) {
42184214
}
42194215

42204216
public void testValidFuse() {
4221-
assumeTrue("FUSE requires corresponding capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
4222-
42234217
LogicalPlan plan = statement("""
42244218
FROM foo* METADATA _id, _index, _score
42254219
| FORK ( WHERE a:"baz" )
@@ -4318,8 +4312,6 @@ public void testValidFuse() {
43184312
}
43194313

43204314
public void testInvalidFuse() {
4321-
assumeTrue("FUSE requires corresponding capability", EsqlCapabilities.Cap.FUSE_V6.isEnabled());
4322-
43234315
String queryPrefix = "from test metadata _score, _index, _id | fork (where true) (where true)";
43244316

43254317
expectError(queryPrefix + " | FUSE BLA", "line 1:75: Fuse type BLA is not supported");

0 commit comments

Comments
 (0)