File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
server/src/main/java/org/elasticsearch/ingest Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -79,6 +79,7 @@ public static IngestStats read(StreamInput in) throws IOException {
7979 for (var i = 0 ; i < size ; i ++) {
8080 ProjectId projectId = in .getTransportVersion ().onOrAfter (TransportVersions .NODES_STATS_SUPPORTS_MULTI_PROJECT )
8181 ? ProjectId .readFrom (in )
82+ // We will not have older nodes in a multi-project cluster, so we can assume that everything is in the default cluster.
8283 : Metadata .DEFAULT_PROJECT_ID ;
8384 var pipelineId = in .readString ();
8485 var pipelineStat = readStats (in );
@@ -106,7 +107,6 @@ public void writeTo(StreamOutput out) throws IOException {
106107 totalStats .writeTo (out );
107108 out .writeVInt (pipelineStats .size ());
108109 for (PipelineStat pipelineStat : pipelineStats ) {
109- // TODO: This now behaves differently to NodeIndicesStats. Once we've agreed an approach, we should make them consistent.
110110 if (out .getTransportVersion ().onOrAfter (TransportVersions .NODES_STATS_SUPPORTS_MULTI_PROJECT )) {
111111 pipelineStat .projectId ().writeTo (out );
112112 }
You can’t perform that action at this time.
0 commit comments