Skip to content

Commit 6b9aa4d

Browse files
committed
update usage
1 parent e3c5383 commit 6b9aa4d

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import org.elasticsearch.action.index.IndexRequest;
1111
import org.elasticsearch.action.support.WriteRequest;
1212
import org.elasticsearch.cluster.metadata.IndexMetadata;
13-
import org.elasticsearch.cluster.project.TestProjectResolvers;
13+
import org.elasticsearch.cluster.metadata.ProjectId;
1414
import org.elasticsearch.common.settings.Settings;
1515
import org.elasticsearch.common.util.CollectionUtils;
1616
import org.elasticsearch.compute.operator.exchange.ExchangeService;
@@ -132,8 +132,7 @@ public void testRetryOnShardMovement() {
132132
(handler, request, channel, task) -> {
133133
// move index shard
134134
if (shouldMove.compareAndSet(true, false)) {
135-
var projectState = TestProjectResolvers.DEFAULT_PROJECT_ONLY.getProjectState(clusterService().state());
136-
var shardRouting = projectState.routingTable().shardRoutingTable("index-1", 0);
135+
var shardRouting = clusterService().state().routingTable(ProjectId.DEFAULT).shardRoutingTable("index-1", 0);
137136
var currentShardNodeId = shardRouting.primaryShard().currentNodeId();
138137
assertAcked(
139138
client().admin()

0 commit comments

Comments
 (0)