Fixed unnecessary change

Signed-off-by: Krishna Kondaka <[email protected]>
kkondaka · Nov 2, 2023 · 057b9d1 · 057b9d1
1 parent 5a9ab5c
commit 057b9d1
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...arch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java b/...arch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java
@@ -236,8 +236,7 @@ private void doInitializeInternal() throws IOException {
                     .setParameter("filter_path", "errors,took,items.*.error,items.*.status,items.*._index,items.*._id")
                     .build());
     bulkApiWrapper = BulkApiWrapperFactory.getWrapper(openSearchSinkConfig.getIndexConfiguration(), filteringOpenSearchClient);
-    bulkRetryStrategy = new BulkRetryStrategy(this,
-            bulkRequest -> bulkApiWrapper.bulk(bulkRequest.getRequest()),
+    bulkRetryStrategy = new BulkRetryStrategy(bulkRequest -> bulkApiWrapper.bulk(bulkRequest.getRequest()),
             this::logFailureForBulkRequests,
             pluginMetrics,
             maxRetries,