diff --git a/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java b/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java index f3002c8c74..ace3a35dac 100644 --- a/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java +++ b/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java @@ -996,7 +996,7 @@ public void testEventOutputWithSpecialAndExtremeValues(final Object testValue) t expectedContent.put(testField, testValue); assertThat(retSources.size(), equalTo(1)); - assertThat(retSources.containsAll(Arrays.asList(expectedContent)), equalTo(true)); + assertThat(retSources.get(0), equalTo(expectedContent)); sink.shutdown(); }