From e1aa05dd695144fdb609e35b770e6fc17b89ea6d Mon Sep 17 00:00:00 2001
From: Krishna Kondaka
 <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
Date: Tue, 23 Jul 2024 20:22:33 +0000
Subject: [PATCH] cleanup

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
---
 .../plugins/sink/opensearch/OpenSearchSink.java       | 11 -----------
 1 file changed, 11 deletions(-)

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 ff763ad24a..1b6f44fde6 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
@@ -591,7 +591,6 @@ private void closeFiles() {
     if (restHighLevelClient != null) {
       try {
         restHighLevelClient.close();
-        restHighLevelClient = null;
       } catch (final IOException e) {
         throw new RuntimeException(e.getMessage(), e);
       }
@@ -599,7 +598,6 @@ private void closeFiles() {
     if (dlqWriter != null) {
       try {
         dlqWriter.close();
-        dlqWriter = null;
       } catch (final IOException e) {
         LOG.error(e.getMessage(), e);
       }
@@ -607,7 +605,6 @@ private void closeFiles() {
     if (dlqFileWriter != null) {
       try {
         dlqFileWriter.close();
-        dlqFileWriter = null;
       } catch (final IOException e) {
         LOG.error(e.getMessage(), e);
       }
@@ -619,14 +616,6 @@ public void shutdown() {
     super.shutdown();
     closeFiles();
     openSearchClient.shutdown();
-    // Explicitly set to null to make the GC faster.
-    // This is useful in cases of sink initialize retry
-    openSearchClient = null;
-    openSearchClientRefresher = null;
-    bulkRetryStrategy = null;
-    bulkApiWrapper = null;
-    bulkRequestSupplier = null;
-    initialized = false;
   }
 
   private void maybeUpdateServerlessNetworkPolicy() {