Skip to content

Commit 6fe6c45

Browse files
Yury-FridlyandMaxKsyunz
andcommitted
Fix plugin compilation (opensearch-project#1580)
* Changed gradle version and removed values iterator Signed-off-by: Guian Gumpac <[email protected]> * Update a test to match new indexResponse.aliases() type. Signed-off-by: MaxKsyunz <[email protected]> * Ran ./gradlew wrapper Signed-off-by: Guian Gumpac <[email protected]> --------- Signed-off-by: Guian Gumpac <[email protected]> Signed-off-by: MaxKsyunz <[email protected]> Co-authored-by: MaxKsyunz <[email protected]> Signed-off-by: Yury-Fridlyand <[email protected]>
1 parent 8558e90 commit 6fe6c45

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

opensearch/src/main/java/org/opensearch/sql/opensearch/client/OpenSearchNodeClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ public List<String> indices() {
151151
.setLocal(true)
152152
.get();
153153
final Stream<String> aliasStream =
154-
ImmutableList.copyOf(indexResponse.aliases().valuesIt()).stream()
154+
ImmutableList.copyOf(indexResponse.aliases().values()).stream()
155155
.flatMap(Collection::stream).map(AliasMetadata::alias);
156156

157157
return Stream.concat(Arrays.stream(indexResponse.getIndices()), aliasStream)

opensearch/src/test/java/org/opensearch/sql/opensearch/client/OpenSearchNodeClientTest.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -399,9 +399,7 @@ void cleanup_rethrows_exception() {
399399
@Test
400400
void get_indices() {
401401
AliasMetadata aliasMetadata = mock(AliasMetadata.class);
402-
ImmutableOpenMap.Builder<String, List<AliasMetadata>> builder = ImmutableOpenMap.builder();
403-
builder.fPut("index", Arrays.asList(aliasMetadata));
404-
final ImmutableOpenMap<String, List<AliasMetadata>> openMap = builder.build();
402+
final var openMap = Map.of("index", List.of(aliasMetadata));
405403
when(aliasMetadata.alias()).thenReturn("index_alias");
406404
when(nodeClient.admin().indices()
407405
.prepareGetIndex()

0 commit comments

Comments
 (0)