From ed34e34b86a6236b4f4d21260703074de069fa3e Mon Sep 17 00:00:00 2001
From: Konstantinos Kloudas <konstantinos.kloudas@snowflake.com>
Date: Fri, 22 Apr 2022 13:06:10 +0000
Subject: [PATCH] SNOW-569611 do not allow concurrent client.close()

---
 .../internal/SnowflakeStreamingIngestClientInternal.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java b/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java
index f4abef7c3..dcec464ba 100644
--- a/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java
+++ b/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java
@@ -528,7 +528,7 @@ List<BlobMetadata> getRetryBlobs(
 
   /** Close the client, which will flush first and then release all the resources */
   @Override
-  public void close() throws Exception {
+  public synchronized void close() throws Exception {
     if (isClosed) {
       return;
     }