Skip to content

Commit 875bbfe

Browse files
committed
Backported the harden synced-flush PR to v6.3.0
Relates elastic#28464
1 parent 459233d commit 875bbfe

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/elasticsearch/indices/flush/SyncedFlushService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -533,7 +533,7 @@ int numDocs() {
533533
public void readFrom(StreamInput in) throws IOException {
534534
super.readFrom(in);
535535
commitId = new Engine.CommitId(in);
536-
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
536+
if (in.getVersion().onOrAfter(Version.V_6_3_0)) {
537537
numDocs = in.readInt();
538538
} else {
539539
numDocs = UNKNOWN_NUM_DOCS;
@@ -544,7 +544,7 @@ public void readFrom(StreamInput in) throws IOException {
544544
public void writeTo(StreamOutput out) throws IOException {
545545
super.writeTo(out);
546546
commitId.writeTo(out);
547-
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
547+
if (out.getVersion().onOrAfter(Version.V_6_3_0)) {
548548
out.writeInt(numDocs);
549549
}
550550
}

0 commit comments

Comments
 (0)