We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eeece78 commit 66cb081Copy full SHA for 66cb081
clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHousePipedStream.java
@@ -103,7 +103,10 @@ public void close() throws IOException {
103
Thread.currentThread().interrupt();
104
throw new IOException("Thread was interrupted when putting EMPTY buffer into queue", e);
105
} finally {
106
- super.close();
+ closed = true;
107
+ if (postCloseAction != null) {
108
+ postCloseAction.run();
109
+ }
110
}
111
112
0 commit comments