honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adjust bwc for recovery request (#33693) 

Relates #33693
This commit is contained in:
Nhat Nguyen 2018-09-22 19:28:20 -04:00
parent e7ae2f9d36
commit f2f08dd6c5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/src/main/java/org/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest.java
View File

@ -77,7 +77,7 @@ public class RecoveryTranslogOperationsRequest extends TransportRequest {
shardId = ShardId.readShardId(in); shardId = ShardId.readShardId(in);
operations = Translog.readOperations(in, "recovery"); operations = Translog.readOperations(in, "recovery");
totalTranslogOps = in.readVInt(); totalTranslogOps = in.readVInt();
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) { if (in.getVersion().onOrAfter(Version.V_6_5_0)) {
maxSeenAutoIdTimestampOnPrimary = in.readZLong(); maxSeenAutoIdTimestampOnPrimary = in.readZLong();
} else { } else {
maxSeenAutoIdTimestampOnPrimary = IndexRequest.UNSET_AUTO_GENERATED_TIMESTAMP; maxSeenAutoIdTimestampOnPrimary = IndexRequest.UNSET_AUTO_GENERATED_TIMESTAMP;
@ -91,7 +91,7 @@ public class RecoveryTranslogOperationsRequest extends TransportRequest {
shardId.writeTo(out); shardId.writeTo(out);
Translog.writeOperations(out, operations); Translog.writeOperations(out, operations);
out.writeVInt(totalTranslogOps); out.writeVInt(totalTranslogOps);
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) { if (out.getVersion().onOrAfter(Version.V_6_5_0)) {
out.writeZLong(maxSeenAutoIdTimestampOnPrimary); out.writeZLong(maxSeenAutoIdTimestampOnPrimary);
} }
} }