Skip to content

Commit 11fa5c6

Browse files
committed
[TEST] Fix random test failure in GetWatchResponseTests
1 parent acdf966 commit 11fa5c6

File tree

3 files changed

+8
-7
lines changed

3 files changed

+8
-7
lines changed

client/rest-high-level/src/main/java/org/elasticsearch/client/watcher/WatchStatus.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.joda.time.DateTime;
2727

2828
import java.io.IOException;
29+
import java.util.Collections;
2930
import java.util.HashMap;
3031
import java.util.Map;
3132
import java.util.Objects;
@@ -125,7 +126,7 @@ public static WatchStatus parse(XContentParser parser) throws IOException {
125126
DateTime lastChecked = null;
126127
DateTime lastMetCondition = null;
127128
Map<String, ActionStatus> actions = null;
128-
Map<String, String> headers = null;
129+
Map<String, String> headers = Collections.emptyMap();
129130
long version = -1;
130131

131132
ensureExpectedToken(XContentParser.Token.START_OBJECT, parser.currentToken(), parser::getTokenLocation);

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/watcher/watch/WatchStatus.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,8 @@ public void readFrom(StreamInput in) throws IOException {
234234
}
235235
if (in.readBoolean()) {
236236
headers = in.readMap(StreamInput::readString, StreamInput::readString);
237+
} else {
238+
headers = Collections.emptyMap();
237239
}
238240
}
239241

x-pack/plugin/core/src/test/java/org/elasticsearch/protocol/xpack/watcher/GetWatchResponseTests.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -140,12 +140,10 @@ private static WatchStatus randomWatchStatus() {
140140
);
141141
actionMap.put(randomAlphaOfLength(10), actionStatus);
142142
}
143-
Map<String, String> headers = randomBoolean() ? new HashMap<>() : null;
144-
if (headers != null) {
145-
int headerSize = randomIntBetween(1, 5);
146-
for (int i = 0; i < headerSize; i++) {
147-
headers.put(randomAlphaOfLengthBetween(5, 10), randomAlphaOfLengthBetween(1, 10));
148-
}
143+
Map<String, String> headers = new HashMap<>();
144+
int headerSize = randomIntBetween(0, 5);
145+
for (int i = 0; i < headerSize; i++) {
146+
headers.put(randomAlphaOfLengthBetween(5, 10), randomAlphaOfLengthBetween(1, 10));
149147
}
150148
return new WatchStatus(version, state, executionState, lastChecked, lastMetCondition, actionMap, headers);
151149
}

0 commit comments

Comments
 (0)