Skip to content

Commit 79324e3

Browse files
committed
fix another tests relying on score mode logging
1 parent 433329f commit 79324e3

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ public void testTaskContents() throws Exception {
167167
\\_AggregationOperator[mode = INITIAL, aggs = sum of longs]
168168
\\_ExchangeSinkOperator""".replace(
169169
"sourceStatus",
170-
"dataPartitioning = SHARD, maxPageSize = " + pageSize() + ", limit = 2147483647, scoreMode = COMPLETE_NO_SCORES"
170+
"dataPartitioning = SHARD, maxPageSize = " + pageSize() + ", limit = 2147483647, needsScore = false"
171171
)
172172
)
173173
);
@@ -502,7 +502,7 @@ public void testTaskContentsForTopNQuery() throws Exception {
502502
[{"pause_me":{"order":"asc","missing":"_last","unmapped_type":"long"}}]""";
503503
String sourceStatus = "dataPartitioning = SHARD, maxPageSize = "
504504
+ pageSize()
505-
+ ", limit = 1000, scoreMode = TOP_DOCS, sorts = "
505+
+ ", limit = 1000, needsScore = false, sorts = "
506506
+ sortStatus;
507507
assertThat(dataTasks(tasks).get(0).description(), equalTo("""
508508
\\_LuceneTopNSourceOperator[sourceStatus]
@@ -545,7 +545,7 @@ public void testTaskContentsForLimitQuery() throws Exception {
545545
scriptPermits.release(pageSize() - prereleasedDocs);
546546
List<TaskInfo> tasks = getTasksRunning();
547547
assertThat(dataTasks(tasks).get(0).description(), equalTo("""
548-
\\_LuceneSourceOperator[dataPartitioning = SHARD, maxPageSize = pageSize(), limit = limit(), scoreMode = COMPLETE_NO_SCORES]
548+
\\_LuceneSourceOperator[dataPartitioning = SHARD, maxPageSize = pageSize(), limit = limit(), needsScore = false]
549549
\\_ValuesSourceReaderOperator[fields = [pause_me]]
550550
\\_ProjectOperator[projection = [1]]
551551
\\_ExchangeSinkOperator""".replace("pageSize()", Integer.toString(pageSize())).replace("limit()", limit)));
@@ -573,7 +573,7 @@ public void testTaskContentsForGroupingStatsQuery() throws Exception {
573573
logger.info("unblocking script");
574574
scriptPermits.release(pageSize());
575575
List<TaskInfo> tasks = getTasksRunning();
576-
String sourceStatus = "dataPartitioning = SHARD, maxPageSize = pageSize(), limit = 2147483647, scoreMode = COMPLETE_NO_SCORES"
576+
String sourceStatus = "dataPartitioning = SHARD, maxPageSize = pageSize(), limit = 2147483647, needsScore = false"
577577
.replace("pageSize()", Integer.toString(pageSize()));
578578
assertThat(
579579
dataTasks(tasks).get(0).description(),

0 commit comments

Comments
 (0)