Skip to content

Commit e100f88

Browse files
Tidy up ClusterStatsNodeRequest (#116036)
There was an `@UpdateForV9` on this class saying that it could be replaced with `TransportRequest.Empty`. But that was removed by #109790, and all its non-test usages replaced by trivial implementations of `TransportRequest`. This change therefore just simplifies the class a bit and removes that annotation.
1 parent 8b9cbca commit e100f88

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

server/src/main/java/org/elasticsearch/action/admin/cluster/stats/TransportClusterStatsAction.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,9 @@
3535
import org.elasticsearch.cluster.node.DiscoveryNode;
3636
import org.elasticsearch.cluster.service.ClusterService;
3737
import org.elasticsearch.common.io.stream.StreamInput;
38-
import org.elasticsearch.common.io.stream.StreamOutput;
3938
import org.elasticsearch.common.settings.Settings;
4039
import org.elasticsearch.common.util.CancellableSingleObjectCache;
4140
import org.elasticsearch.common.util.concurrent.ThreadContext;
42-
import org.elasticsearch.core.UpdateForV9;
4341
import org.elasticsearch.index.IndexService;
4442
import org.elasticsearch.index.engine.CommitStats;
4543
import org.elasticsearch.index.seqno.RetentionLeaseStats;
@@ -307,7 +305,6 @@ protected ClusterStatsNodeResponse nodeOperation(ClusterStatsNodeRequest nodeReq
307305
);
308306
}
309307

310-
@UpdateForV9(owner = UpdateForV9.Owner.DATA_MANAGEMENT) // this can be replaced with TransportRequest.Empty in v9
311308
public static class ClusterStatsNodeRequest extends TransportRequest {
312309

313310
ClusterStatsNodeRequest() {}
@@ -320,11 +317,6 @@ public ClusterStatsNodeRequest(StreamInput in) throws IOException {
320317
public Task createTask(long id, String type, String action, TaskId parentTaskId, Map<String, String> headers) {
321318
return new CancellableTask(id, type, action, "", parentTaskId, headers);
322319
}
323-
324-
@Override
325-
public void writeTo(StreamOutput out) throws IOException {
326-
super.writeTo(out);
327-
}
328320
}
329321

330322
private static class MetadataStatsCache<T> extends CancellableSingleObjectCache<Metadata, Long, T> {

0 commit comments

Comments
 (0)