Skip to content

Commit af788a0

Browse files
SNOW-569611 do not allow concurrent client.close()
1 parent 3f93314 commit af788a0

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

+1-1
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)