Skip to content

Commit 38c0577

Browse files
committed
enable CVS tests
1 parent a7a23b5 commit 38c0577

File tree

1 file changed

+4
-2
lines changed
  • x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql

1 file changed

+4
-2
lines changed

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/CsvTests.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,7 @@
7777
import org.elasticsearch.xpack.esql.plan.physical.ChangePointExec;
7878
import org.elasticsearch.xpack.esql.plan.physical.HashJoinExec;
7979
import org.elasticsearch.xpack.esql.plan.physical.LocalSourceExec;
80+
import org.elasticsearch.xpack.esql.plan.physical.MergeExec;
8081
import org.elasticsearch.xpack.esql.plan.physical.OutputExec;
8182
import org.elasticsearch.xpack.esql.plan.physical.PhysicalPlan;
8283
import org.elasticsearch.xpack.esql.planner.LocalExecutionPlanner;
@@ -279,7 +280,6 @@ public final void test() throws Throwable {
279280
"CSV tests cannot correctly handle the field caps change",
280281
testCase.requiredCapabilities.contains(EsqlCapabilities.Cap.SEMANTIC_TEXT_FIELD_CAPS.capabilityName())
281282
);
282-
assumeFalse("fork disabled for csv tests", testCase.requiredCapabilities.contains(EsqlCapabilities.Cap.FORK.capabilityName()));
283283
if (Build.current().isSnapshot()) {
284284
assertThat(
285285
"Capability is not included in the enabled list capabilities on a snapshot build. Spelling mistake?",
@@ -566,7 +566,9 @@ private Throwable reworkException(Throwable th) {
566566

567567
// Asserts that the serialization and deserialization of the plan creates an equivalent plan.
568568
private void opportunisticallyAssertPlanSerialization(PhysicalPlan plan) {
569-
if (plan.anyMatch(p -> p instanceof LocalSourceExec || p instanceof HashJoinExec || p instanceof ChangePointExec)) {
569+
if (plan.anyMatch(
570+
p -> p instanceof LocalSourceExec || p instanceof HashJoinExec || p instanceof ChangePointExec || p instanceof MergeExec
571+
)) {
570572
return;
571573
}
572574
SerializationTestUtils.assertSerialization(plan, configuration);

0 commit comments

Comments
 (0)