Remove extra flush when closing piped output stream

Author: zhicwu

clickhouse-client/src/main/java/com/clickhouse/client/stream/BlockingPipedOutputStream.java

@@ -102,7 +102,10 @@ public void close() throws IOException {
             Thread.currentThread().interrupt();
             throw new IOException("Thread was interrupted when putting EMPTY buffer into queue", e);
         } finally {
-            super.close();
+            closed = true;
+            if (postCloseAction != null) {
+                postCloseAction.run();
+            }
         }
     }
 

clickhouse-client/src/main/java/com/clickhouse/client/stream/NonBlockingPipedOutputStream.java

@@ -116,7 +116,11 @@ public void close() throws IOException {
             for (int i = 0, len = buckets.length; i < len; i++) {
                 buckets[i] = null;
             }
-            super.close();
+
+            closed = true;
+            if (postCloseAction != null) {
+                postCloseAction.run();
+            }
         }
     }