Skip to content

Commit ed34e34

Browse files
SNOW-569611 do not allow concurrent client.close()
1 parent 68064f6 commit ed34e34

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -528,7 +528,7 @@ List<BlobMetadata> getRetryBlobs(
528528

529529
/** Close the client, which will flush first and then release all the resources */
530530
@Override
531-
public void close() throws Exception {
531+
public synchronized void close() throws Exception {
532532
if (isClosed) {
533533
return;
534534
}

0 commit comments

Comments
 (0)