Skip to content

Commit 899e7c8

Browse files
committed
Avoid HandleLimitFS in LookupJoinTypesIT
1 parent 4656a53 commit 899e7c8

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

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

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,14 @@
77

88
package org.elasticsearch.xpack.esql.action;
99

10+
import org.apache.lucene.tests.util.LuceneTestCase;
11+
import org.elasticsearch.action.index.IndexRequestBuilder;
1012
import org.elasticsearch.common.settings.Settings;
1113
import org.elasticsearch.index.mapper.extras.MapperExtrasPlugin;
1214
import org.elasticsearch.plugins.Plugin;
1315
import org.elasticsearch.test.ESIntegTestCase;
1416
import org.elasticsearch.test.ESIntegTestCase.ClusterScope;
17+
import org.elasticsearch.xcontent.XContentType;
1518
import org.elasticsearch.xpack.core.esql.action.ColumnInfo;
1619
import org.elasticsearch.xpack.esql.VerificationException;
1720
import org.elasticsearch.xpack.esql.core.type.DataType;
@@ -118,6 +121,7 @@
118121
* And assert that the result exists and is equal to "value".
119122
*/
120123
@ClusterScope(scope = SUITE, numClientNodes = 1, numDataNodes = 1)
124+
@LuceneTestCase.SuppressFileSystems(value = "HandleLimitFS")
121125
public class LookupJoinTypesIT extends ESIntegTestCase {
122126
protected Collection<Class<? extends Plugin>> nodePlugins() {
123127
return List.of(
@@ -361,16 +365,18 @@ private void initIndexes(String group) {
361365
private void initData(String group) {
362366
Collection<TestConfig> configs = testConfigurations.get(group).configs.values();
363367
int docId = 0;
368+
List<IndexRequestBuilder> indexRequests = new ArrayList<>(configs.size());
364369
for (TestConfig config : configs) {
365370
String doc = String.format(Locale.ROOT, """
366371
{
367372
%s,
368373
"other": "value"
369374
}
370375
""", lookupPropertyFor(config));
371-
index(config.indexName(), "" + (++docId), doc);
372-
refresh(config.indexName());
376+
var indexRequest = client().prepareIndex().setIndex(config.indexName()).setId("" + (++docId)).setSource(doc, XContentType.JSON);
377+
indexRequests.add(indexRequest);
373378
}
379+
indexRandom(true, indexRequests);
374380
List<String> mainProperties = configs.stream().map(this::mainPropertyFor).distinct().collect(Collectors.toList());
375381
index("index", "1", String.format(Locale.ROOT, """
376382
{

0 commit comments

Comments
 (0)