Skip to content

Commit 709264a

Browse files
authored
Adjust data stream custom metadata serialization, (elastic#64174)
after backporting elastic#63991 to 7. branch.
1 parent c23c057 commit 709264a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/DataStream.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ public static String getDefaultBackingIndexName(String dataStreamName, long gene
153153

154154
public DataStream(StreamInput in) throws IOException {
155155
this(in.readString(), new TimestampField(in), in.readList(Index::new), in.readVLong(),
156-
in.getVersion().onOrAfter(Version.V_8_0_0) ? in.readMap(): null);
156+
in.getVersion().onOrAfter(Version.V_7_11_0) ? in.readMap(): null);
157157
}
158158

159159
public static Diff<DataStream> readDiffFrom(StreamInput in) throws IOException {
@@ -166,7 +166,7 @@ public void writeTo(StreamOutput out) throws IOException {
166166
timeStampField.writeTo(out);
167167
out.writeList(indices);
168168
out.writeVLong(generation);
169-
if (out.getVersion().onOrAfter(Version.V_8_0_0)) {
169+
if (out.getVersion().onOrAfter(Version.V_7_11_0)) {
170170
out.writeMap(metadata);
171171
}
172172
}

0 commit comments

Comments
 (0)