AnnotationIndexIT.testCreatedWhenAfterOtherMlIndex fails #40933
Description
This test trips a new assertion introduced in #39793.
> Caused by: java.lang.AssertionError: All exceptions should be handled by #executeBulkItemRequest
> at __randomizedtesting.SeedInfo.seed([BE0AD1E3182F462A]:0)
> at org.elasticsearch.action.bulk.TransportShardBulkAction$2.onFailure(TransportShardBulkAction.java:173)
> at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:39)
> at org.elasticsearch.action.bulk.TransportShardBulkAction.performOnPrimary(TransportShardBulkAction.java:197)
> at org.elasticsearch.action.bulk.TransportShardBulkAction.shardOperationOnPrimary(TransportShardBulkAction.java:116)
> at org.elasticsearch.action.bulk.TransportShardBulkAction.shardOperationOnPrimary(TransportShardBulkAction.java:77)
> at org.elasticsearch.action.support.replication.TransportReplicationAction$PrimaryShardReference.perform(TransportReplicationAction.java:927)
> at org.elasticsearch.action.support.replication.ReplicationOperation.execute(ReplicationOperation.java:104)
> at org.elasticsearch.action.support.replication.TransportReplicationAction$AsyncPrimaryAction.runWithPrimaryShardReference(TransportReplicationAction.java:364)
> at org.elasticsearch.action.support.replication.TransportReplicationAction$AsyncPrimaryAction.lambda$doRun$0(TransportReplicationAction.java:311)
> at org.elasticsearch.action.ActionListener$1.onResponse(ActionListener.java:62)
> at org.elasticsearch.index.shard.IndexShardOperationPermits.acquire(IndexShardOperationPermits.java:269)
> at org.elasticsearch.index.shard.IndexShardOperationPermits.acquire(IndexShardOperationPermits.java:236)
> at org.elasticsearch.index.shard.IndexShard.acquirePrimaryOperationPermit(IndexShard.java:2513)
> at org.elasticsearch.action.support.replication.TransportReplicationAction.acquirePrimaryOperationPermit(TransportReplicationAction.java:865)
> at org.elasticsearch.action.support.replication.TransportReplicationAction$AsyncPrimaryAction.doRun(TransportReplicationAction.java:310)
> at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
> at org.elasticsearch.action.support.replication.TransportReplicationAction.handlePrimaryRequest(TransportReplicationAction.java:273)
> at org.elasticsearch.transport.RequestHandlerRegistry.processMessageReceived(RequestHandlerRegistry.java:63)
> at org.elasticsearch.transport.TransportService$7.doRun(TransportService.java:703)
> at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:747)
> at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
This is reproducible with the following line
./gradlew :x-pack:plugin:ml:internalClusterTest \
-Dtests.seed=BE0AD1E3182F462A \
-Dtests.class=org.elasticsearch.xpack.ml.integration.AnnotationIndexIT \
-Dtests.method="testCreatedWhenAfterOtherMlIndex" \
-Dtests.security.manager=true \
-Dtests.jvm.argline="-XX:-UseConcMarkSweepGC -XX:+UseG1GC" \
-Dtests.locale=id \
-Dtests.timezone=Asia/Chita \
-Dcompiler.java=12 \
-Druntime.java=8
CI: https://elasticsearch-ci.elastic.co/job/elastic+elasticsearch+master+g1gc/519/console