|
@@ -126,7 +126,7 @@ public class IndexRequest extends ReplicatedWriteRequest<IndexRequest> implement
|
|
version = in.readLong();
|
|
version = in.readLong();
|
|
versionType = VersionType.fromValue(in.readByte());
|
|
versionType = VersionType.fromValue(in.readByte());
|
|
pipeline = in.readOptionalString();
|
|
pipeline = in.readOptionalString();
|
|
- if (in.getVersion().onOrAfter(Version.V_8_0_0)) {
|
|
|
|
|
|
+ if (in.getVersion().onOrAfter(Version.V_7_5_0)) {
|
|
isPipelineResolved = in.readBoolean();
|
|
isPipelineResolved = in.readBoolean();
|
|
}
|
|
}
|
|
isRetry = in.readBoolean();
|
|
isRetry = in.readBoolean();
|
|
@@ -651,7 +651,7 @@ public class IndexRequest extends ReplicatedWriteRequest<IndexRequest> implement
|
|
out.writeLong(version);
|
|
out.writeLong(version);
|
|
out.writeByte(versionType.getValue());
|
|
out.writeByte(versionType.getValue());
|
|
out.writeOptionalString(pipeline);
|
|
out.writeOptionalString(pipeline);
|
|
- if (out.getVersion().onOrAfter(Version.V_8_0_0)) {
|
|
|
|
|
|
+ if (out.getVersion().onOrAfter(Version.V_7_5_0)) {
|
|
out.writeBoolean(isPipelineResolved);
|
|
out.writeBoolean(isPipelineResolved);
|
|
}
|
|
}
|
|
out.writeBoolean(isRetry);
|
|
out.writeBoolean(isRetry);
|