@@ -107,6 +107,7 @@ private Stats(StreamInput in) throws IOException {
107107 dfsCount = in .readVLong ();
108108 dfsTimeInMillis = in .readVLong ();
109109 dfsCurrent = in .readVLong ();
110+ dfsFailure = in .readVLong ();
110111 }
111112
112113 queryCount = in .readVLong ();
@@ -129,10 +130,6 @@ private Stats(StreamInput in) throws IOException {
129130 queryFailure = in .readVLong ();
130131 fetchFailure = in .readVLong ();
131132 }
132-
133- if (in .getTransportVersion ().onOrAfter (TransportVersions .DFS_STATS )) {
134- dfsFailure = in .readVLong ();
135- }
136133 }
137134
138135 @ Override
@@ -141,6 +138,7 @@ public void writeTo(StreamOutput out) throws IOException {
141138 out .writeVLong (dfsCount );
142139 out .writeVLong (dfsTimeInMillis );
143140 out .writeVLong (dfsCurrent );
141+ out .writeVLong (dfsFailure );
144142 }
145143
146144 out .writeVLong (queryCount );
@@ -163,10 +161,6 @@ public void writeTo(StreamOutput out) throws IOException {
163161 out .writeVLong (queryFailure );
164162 out .writeVLong (fetchFailure );
165163 }
166-
167- if (out .getTransportVersion ().onOrAfter (TransportVersions .DFS_STATS )) {
168- out .writeVLong (dfsFailure );
169- }
170164 }
171165
172166 public void add (Stats stats ) {
0 commit comments