debug

liunaijie · Jun 27, 2024 · 04c0a77 · 04c0a77
1 parent 0890634
commit 04c0a77
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/.../apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkWriter.java b/.../apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkWriter.java
@@ -269,6 +269,7 @@ private List<String> generateClickhouseLocalFiles(String clickhouseLocalFileTmpF
         if (localPaths.size() == 1) {
             command.add("local");
         }
+        command.add("-n");
         command.add("--file");
         command.add(clickhouseLocalFileTmpFile);
         command.add("--format_csv_delimiter");

diff --git a/...tor-v2-e2e/connector-clickhouse-e2e/src/test/resources/clickhouse_to_clickhouse_file.conf b/...tor-v2-e2e/connector-clickhouse-e2e/src/test/resources/clickhouse_to_clickhouse_file.conf
@@ -47,7 +47,7 @@ sink {
       node_free_password = true
       username = "default"
       password = ""
-      clickhouse_local_path = "/bin/clickhouse"
+      clickhouse_local_path = "/bin/clickhouse local"
     }
 
   # If you would like to get more information about how to configure seatunnel and see full list of sink plugins,