autoformatting

snowflakedb · Nov 20, 2023 · 7014658 · 7014658
1 parent 7628b75
commit 7014658
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProvider.java b/src/main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProvider.java
@@ -142,12 +142,14 @@ public void closeClient(
     SnowflakeStreamingIngestClient registeredClient =
         this.registeredClients.getIfPresent(connectorConfig);
     if (registeredClient != null) {
-      // invalidations are processed on the next get or in the background, so we still need to close the client here
+      // invalidations are processed on the next get or in the background, so we still need to close
+      // the client here
       this.registeredClients.invalidate(connectorConfig);
     }
 
     this.streamingClientHandler.closeClient(client);
-    this.streamingClientHandler.closeClient(registeredClient); // in case the given client is different for some reason
+    this.streamingClientHandler.closeClient(
+        registeredClient); // in case the given client is different for some reason
   }
 
   public Map<Map<String, String>, SnowflakeStreamingIngestClient> getRegisteredClients() {