Fix ShardBulkInferenceActionFilterIT#testRestart (elastic#127671)

Simplify and fix the wrong assumptions in these tests.

Closes elastic#127592
Closes elastic#127593
Closes elastic#127594

Author: jimczi

muted-tests.yml

@@ -417,18 +417,6 @@ tests:
 - class: org.elasticsearch.xpack.esql.qa.single_node.GenerativeIT
   method: test
   issue: https://github.com/elastic/elasticsearch/issues/127536
-- class: org.elasticsearch.xpack.inference.action.filter.ShardBulkInferenceActionFilterIT
-  method: testRestart {p0=false p1=false}
-  issue: https://github.com/elastic/elasticsearch/issues/127592
-- class: org.elasticsearch.xpack.inference.action.filter.ShardBulkInferenceActionFilterIT
-  method: testRestart {p0=true p1=false}
-  issue: https://github.com/elastic/elasticsearch/issues/127593
-- class: org.elasticsearch.xpack.inference.action.filter.ShardBulkInferenceActionFilterIT
-  method: testRestart {p0=false p1=true}
-  issue: https://github.com/elastic/elasticsearch/issues/127594
-- class: org.elasticsearch.xpack.inference.action.filter.ShardBulkInferenceActionFilterIT
-  method: testRestart {p0=true p1=true}
-  issue: https://github.com/elastic/elasticsearch/issues/127595
 - class: org.elasticsearch.xpack.test.rest.XPackRestIT
   method: test {p0=ml/data_frame_analytics_cat_apis/Test cat data frame analytics all jobs with header}
   issue: https://github.com/elastic/elasticsearch/issues/127625

x-pack/plugin/inference/src/internalClusterTest/java/org/elasticsearch/xpack/inference/action/filter/ShardBulkInferenceActionFilterIT.java

@@ -9,14 +9,14 @@
 
 import com.carrotsearch.randomizedtesting.annotations.ParametersFactory;
 
-import org.elasticsearch.action.admin.indices.refresh.RefreshRequest;
 import org.elasticsearch.action.bulk.BulkItemResponse;
 import org.elasticsearch.action.bulk.BulkRequestBuilder;
 import org.elasticsearch.action.bulk.BulkResponse;
 import org.elasticsearch.action.delete.DeleteRequestBuilder;
 import org.elasticsearch.action.index.IndexRequestBuilder;
 import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
+import org.elasticsearch.action.support.WriteRequest;
 import org.elasticsearch.action.update.UpdateRequestBuilder;
 import org.elasticsearch.cluster.metadata.IndexMetadata;
 import org.elasticsearch.common.settings.Settings;
@@ -242,12 +242,10 @@ public void testRestart() throws Exception {
 
     private void assertRandomBulkOperations(String indexName, Function<Boolean, Map<String, Object>> sourceSupplier) throws Exception {
         int numHits = numHits(indexName);
-        int totalBulkReqs = randomIntBetween(2, 100);
-        long totalDocs = numHits;
+        int totalBulkReqs = randomIntBetween(2, 10);
         Set<String> ids = new HashSet<>();
-
-        for (int bulkReqs = numHits; bulkReqs < totalBulkReqs; bulkReqs++) {
-            BulkRequestBuilder bulkReqBuilder = client().prepareBulk();
+        for (int bulkReqs = 0; bulkReqs < totalBulkReqs; bulkReqs++) {
+            BulkRequestBuilder bulkReqBuilder = client().prepareBulk().setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
             int totalBulkSize = randomIntBetween(1, 100);
             for (int bulkSize = 0; bulkSize < totalBulkSize; bulkSize++) {
                 if (ids.size() > 0 && rarely(random())) {
@@ -257,24 +255,15 @@ private void assertRandomBulkOperations(String indexName, Function<Boolean, Map<
                     bulkReqBuilder.add(request);
                     continue;
                 }
-                String id = Long.toString(totalDocs++);
-                boolean isIndexRequest = randomBoolean();
+                boolean isIndexRequest = ids.size() == 0 || randomBoolean();
                 Map<String, Object> source = sourceSupplier.apply(isIndexRequest);
                 if (isIndexRequest) {
+                    String id = randomAlphaOfLength(20);
                     bulkReqBuilder.add(new IndexRequestBuilder(client()).setIndex(indexName).setId(id).setSource(source));
                     ids.add(id);
                 } else {
-                    boolean isUpsert = randomBoolean();
-                    UpdateRequestBuilder request = new UpdateRequestBuilder(client()).setIndex(indexName).setDoc(source);
-                    if (isUpsert || ids.size() == 0) {
-                        request.setDocAsUpsert(true);
-                    } else {
-                        // Update already existing document
-                        id = randomFrom(ids);
-                    }
-                    request.setId(id);
-                    bulkReqBuilder.add(request);
-                    ids.add(id);
+                    String id = randomFrom(ids);
+                    bulkReqBuilder.add(new UpdateRequestBuilder(client()).setIndex(indexName).setId(id).setDoc(source));
                 }
             }
             BulkResponse bulkResponse = bulkReqBuilder.get();
@@ -293,8 +282,7 @@ private void assertRandomBulkOperations(String indexName, Function<Boolean, Map<
             }
             assertFalse(bulkResponse.hasFailures());
         }
-        client().admin().indices().refresh(new RefreshRequest(indexName)).get();
-        assertThat(numHits(indexName), equalTo(ids.size() + numHits));
+        assertThat(numHits(indexName), equalTo(numHits + ids.size()));
     }
 
     private int numHits(String indexName) throws Exception {