Skip to content

Commit 41925e1

Browse files
committed
Bump BWC version for settings serialization to 6.1.0
1 parent b27e408 commit 41925e1

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

core/src/main/java/org/elasticsearch/common/settings/Settings.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -545,7 +545,7 @@ public int hashCode() {
545545
public static Settings readSettingsFromStream(StreamInput in) throws IOException {
546546
Builder builder = new Builder();
547547
int numberOfSettings = in.readVInt();
548-
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
548+
if (in.getVersion().onOrAfter(Version.V_6_1_0)) {
549549
for (int i = 0; i < numberOfSettings; i++) {
550550
String key = in.readString();
551551
Object value = in.readGenericValue();
@@ -570,7 +570,7 @@ public static Settings readSettingsFromStream(StreamInput in) throws IOException
570570
public static void writeSettingsToStream(Settings settings, StreamOutput out) throws IOException {
571571
// pull settings to exclude secure settings in size()
572572
Set<Map.Entry<String, Object>> entries = settings.settings.entrySet();
573-
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
573+
if (out.getVersion().onOrAfter(Version.V_6_1_0)) {
574574
out.writeVInt(entries.size());
575575
for (Map.Entry<String, Object> entry : entries) {
576576
out.writeString(entry.getKey());

core/src/test/java/org/elasticsearch/common/settings/SettingsTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -648,7 +648,7 @@ public void testMissingValue() throws Exception {
648648

649649
public void testReadLegacyFromStream() throws IOException {
650650
BytesStreamOutput output = new BytesStreamOutput();
651-
output.setVersion(VersionUtils.getPreviousVersion(Version.CURRENT));
651+
output.setVersion(VersionUtils.getPreviousVersion(Version.V_6_1_0));
652652
output.writeVInt(5);
653653
output.writeString("foo.bar.1");
654654
output.writeOptionalString("1");
@@ -661,7 +661,7 @@ public void testReadLegacyFromStream() throws IOException {
661661
output.writeString("foo.bar.baz");
662662
output.writeOptionalString("baz");
663663
StreamInput in = StreamInput.wrap(BytesReference.toBytes(output.bytes()));
664-
in.setVersion(VersionUtils.getPreviousVersion(Version.CURRENT));
664+
in.setVersion(VersionUtils.getPreviousVersion(Version.V_6_1_0));
665665
Settings settings = Settings.readSettingsFromStream(in);
666666
assertEquals(2, settings.size());
667667
assertArrayEquals(new String[]{"0", "1", "2", "3"}, settings.getAsArray("foo.bar"));
@@ -670,7 +670,7 @@ public void testReadLegacyFromStream() throws IOException {
670670

671671
public void testWriteLegacyOutput() throws IOException {
672672
BytesStreamOutput output = new BytesStreamOutput();
673-
output.setVersion(VersionUtils.getPreviousVersion(Version.CURRENT));
673+
output.setVersion(VersionUtils.getPreviousVersion(Version.V_6_1_0));
674674
Settings settings = Settings.builder().putArray("foo.bar", "0", "1", "2", "3")
675675
.put("foo.bar.baz", "baz").putNull("foo.null").build();
676676
Settings.writeSettingsToStream(settings, output);
@@ -700,7 +700,7 @@ public void testWriteLegacyOutput() throws IOException {
700700

701701
public void testReadWriteArray() throws IOException {
702702
BytesStreamOutput output = new BytesStreamOutput();
703-
output.setVersion(Version.CURRENT);
703+
output.setVersion(randomFrom(Version.CURRENT, Version.V_6_1_0));
704704
Settings settings = Settings.builder().putArray("foo.bar", "0", "1", "2", "3").put("foo.bar.baz", "baz").build();
705705
Settings.writeSettingsToStream(settings, output);
706706
StreamInput in = StreamInput.wrap(BytesReference.toBytes(output.bytes()));

0 commit comments

Comments
 (0)