Fix unecessary logging for query manager with 0 terms

Signed-off-by: Taylor Gray <tylgry@amazon.com>

Author: graytaylor0

data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java

@@ -452,6 +452,7 @@ private Counter getDocumentStatusCounter(final int status) {
 
     private boolean shouldSendAllForQuerying(final Exception exception) {
         if (exception != null && existingDocumentQueryManager != null) {
+            LOG.warn("Received exception that may result in querying for duplicate documents", exception);
             if (SOCKET_TIMEOUT_EXCEPTIONS.contains(exception.getClass())) {
                 return true;
             }

data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/index/ExistingDocumentQueryManager.java

@@ -125,7 +125,7 @@ public void run() {
 
     @VisibleForTesting
     void runQueryLoop() {
-        if (!bulkOperationsWaitingForQuery.isEmpty()) {
+        if (!bulkOperationsWaitingForQuery.isEmpty() && documentsCurrentlyBeingQueriedGauge.get() > 0) {
 
             // Query for existing documents
             final MsearchRequest msearchRequest = buildMultiSearchRequest();
@@ -197,7 +197,7 @@ private MsearchRequest buildMultiSearchRequest() {
                     m.searches(s -> s
                             .header(h -> h.index(index))
                             .body(b -> b
-                                    .size(chunk.size())
+                                    .size(chunk.size() * 2)
                                     .source(source -> source.filter(f -> f.includes(queryTerm)))
                                     .query(Query.of(q -> q
                                             .terms(TermsQuery.of(t -> t

data-prepper-plugins/opensearch/src/test/java/org/opensearch/dataprepper/plugins/sink/opensearch/index/ExistingDocumentQueryManagerTest.java

@@ -128,6 +128,7 @@ void add_bulk_operation_and_found_in_query_drops_and_releases_event() throws IOE
         final ExistingDocumentQueryManager objectUnderTest = createObjectUnderTest();
 
         objectUnderTest.addBulkOperation(bulkOperationWrapper);
+        when(documentsCurrentlyQueried.get()).thenReturn(1);
 
         objectUnderTest.runQueryLoop();
 
@@ -181,6 +182,8 @@ void add_bulk_operation_and_not_found_in_query_returns_as_ready_to_ingest() thro
 
         objectUnderTest.addBulkOperation(bulkOperationWrapper);
 
+        when(documentsCurrentlyQueried.get()).thenReturn(1);
+
         Thread.sleep(20);
 
         objectUnderTest.runQueryLoop();
@@ -287,6 +290,7 @@ void query_response_with_two_documents_with_same_term_value_tracks_duplicate_doc
         final ExistingDocumentQueryManager objectUnderTest = createObjectUnderTest();
 
         objectUnderTest.addBulkOperation(bulkOperationWrapper);
+        when(documentsCurrentlyQueried.get()).thenReturn(1);
 
         objectUnderTest.runQueryLoop();