Fix version in testDiscoveryNodeRoleWithOldVersion
This commits fixes the version when reading from the stream in DiscoveryNodeTests#testDiscoveryNodeRoleWithOldVersion. Closes #64385
This commit is contained in:
parent
533b929e6c
commit
6b119a43c1
|
@ -133,7 +133,7 @@ public class DiscoveryNodeTests extends ESTestCase {
|
||||||
node.writeTo(streamOutput);
|
node.writeTo(streamOutput);
|
||||||
|
|
||||||
StreamInput in = StreamInput.wrap(streamOutput.bytes().toBytesRef().bytes);
|
StreamInput in = StreamInput.wrap(streamOutput.bytes().toBytesRef().bytes);
|
||||||
in.setVersion(Version.V_7_10_0);
|
in.setVersion(Version.V_7_9_0);
|
||||||
DiscoveryNode serialized = new DiscoveryNode(in);
|
DiscoveryNode serialized = new DiscoveryNode(in);
|
||||||
assertThat(serialized.getRoles().stream().map(DiscoveryNodeRole::roleName).collect(Collectors.joining()),
|
assertThat(serialized.getRoles().stream().map(DiscoveryNodeRole::roleName).collect(Collectors.joining()),
|
||||||
equalTo("data"));
|
equalTo("data"));
|
||||||
|
|
Loading…
Reference in New Issue