|
6 | 6 | */ |
7 | 7 | package org.elasticsearch.xpack.core.ml.action; |
8 | 8 |
|
| 9 | +import org.elasticsearch.action.ActionRequest; |
9 | 10 | import org.elasticsearch.action.ActionRequestValidationException; |
10 | 11 | import org.elasticsearch.action.ActionType; |
11 | | -import org.elasticsearch.action.support.master.MasterNodeReadRequest; |
12 | 12 | import org.elasticsearch.cluster.ClusterState; |
13 | 13 | import org.elasticsearch.cluster.node.DiscoveryNode; |
14 | 14 | import org.elasticsearch.common.io.stream.StreamInput; |
15 | 15 | import org.elasticsearch.common.io.stream.StreamOutput; |
16 | 16 | import org.elasticsearch.common.io.stream.Writeable; |
17 | 17 | import org.elasticsearch.core.Nullable; |
18 | | -import org.elasticsearch.core.UpdateForV9; |
19 | 18 | import org.elasticsearch.persistent.PersistentTasksCustomMetadata; |
20 | 19 | import org.elasticsearch.tasks.CancellableTask; |
21 | 20 | import org.elasticsearch.tasks.Task; |
@@ -58,21 +57,14 @@ private GetDatafeedsStatsAction() { |
58 | 57 | super(NAME); |
59 | 58 | } |
60 | 59 |
|
61 | | - // This needs to be a MasterNodeReadRequest even though the corresponding transport |
62 | | - // action is a HandledTransportAction so that in mixed version clusters it can be |
63 | | - // serialized to older nodes where the transport action was a MasterNodeReadAction. |
64 | | - // TODO: Make this a simple request in a future version where there is no possibility |
65 | | - // of this request being serialized to another node. |
66 | | - @UpdateForV9(owner = UpdateForV9.Owner.MACHINE_LEARNING) |
67 | | - public static class Request extends MasterNodeReadRequest<Request> { |
| 60 | + public static class Request extends ActionRequest { |
68 | 61 |
|
69 | 62 | public static final String ALLOW_NO_MATCH = "allow_no_match"; |
70 | 63 |
|
71 | 64 | private final String datafeedId; |
72 | 65 | private boolean allowNoMatch = true; |
73 | 66 |
|
74 | 67 | public Request(String datafeedId) { |
75 | | - super(TRAPPY_IMPLICIT_DEFAULT_MASTER_NODE_TIMEOUT); |
76 | 68 | this.datafeedId = ExceptionsHelper.requireNonNull(datafeedId, DatafeedConfig.ID.getPreferredName()); |
77 | 69 | } |
78 | 70 |
|
|
0 commit comments