diff --git a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java index caa8d0ab51..10d7ea1ca6 100644 --- a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java +++ b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java @@ -329,7 +329,6 @@ private void flushBatch(AccumulatingBulkRequest accumulatingBulkRequest) { bulkRequestTimer.record(() -> { try { LOG.debug("Sending data to OpenSearch"); - LOG.warn("Flushing batch with {} operations", accumulatingBulkRequest.getOperationsCount()); bulkRetryStrategy.execute(accumulatingBulkRequest); bulkRequestSizeBytesSummary.record(accumulatingBulkRequest.getEstimatedSizeInBytes()); } catch (final InterruptedException e) {