Skip to content

Commit 2d30b92

Browse files
committed
Fix compilation after elastic#123784
1 parent 973c952 commit 2d30b92

File tree

2 files changed

+32
-2
lines changed

2 files changed

+32
-2
lines changed

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/lucene/LuceneSourceOperatorTests.java

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import org.elasticsearch.compute.test.OperatorTestCase;
3333
import org.elasticsearch.compute.test.TestResultPageSinkOperator;
3434
import org.elasticsearch.core.IOUtils;
35+
import org.elasticsearch.core.TimeValue;
3536
import org.elasticsearch.index.cache.query.TrivialQueryCachingPolicy;
3637
import org.elasticsearch.index.mapper.MappedFieldType;
3738
import org.elasticsearch.index.mapper.NumberFieldMapper;
@@ -144,7 +145,21 @@ public void testEarlyTermination() {
144145
receivedRows.addAndGet(p.getPositionCount());
145146
p.releaseBlocks();
146147
});
147-
Driver driver = new Driver("driver" + i, driverContext, sourceOperator, List.of(), sinkOperator, () -> {});
148+
Driver driver = new Driver(
149+
"driver" + i,
150+
"test",
151+
"cluster",
152+
"node",
153+
0,
154+
0,
155+
driverContext,
156+
() -> "test",
157+
sourceOperator,
158+
List.of(),
159+
sinkOperator,
160+
TimeValue.timeValueNanos(1),
161+
() -> {}
162+
);
148163
drivers.add(driver);
149164
}
150165
OperatorTestCase.runDriver(drivers);

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/operator/LimitOperatorTests.java

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import org.elasticsearch.compute.test.OperatorTestCase;
1414
import org.elasticsearch.compute.test.RandomBlock;
1515
import org.elasticsearch.compute.test.SequenceLongBlockSourceOperator;
16+
import org.elasticsearch.core.TimeValue;
1617
import org.hamcrest.Matcher;
1718

1819
import java.util.ArrayList;
@@ -164,7 +165,21 @@ public void close() {
164165
p.releaseBlocks();
165166
});
166167
drivers.add(
167-
new Driver("driver" + i, driverContext, sourceOperator, List.of(limitFactory.get(driverContext)), sinkOperator, () -> {})
168+
new Driver(
169+
"unset",
170+
"test",
171+
"cluster",
172+
"node",
173+
0,
174+
0,
175+
driverContext,
176+
() -> "test",
177+
sourceOperator,
178+
List.of(limitFactory.get(driverContext)),
179+
sinkOperator,
180+
TimeValue.timeValueMillis(1),
181+
() -> {}
182+
)
168183
);
169184
}
170185
runDriver(drivers);

0 commit comments

Comments
 (0)