(seatunnel) branch dev updated: [Improve][ClickhouseFile] ClickhouseFile Connector's rsync transmission supports specifying users (#8236)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new e012bd0a4f [Improve][ClickhouseFile] ClickhouseFile Connector's rsync 
transmission supports specifying users (#8236)
e012bd0a4f is described below

commit e012bd0a4fe1c1b2e7a0a2735553713fc8faf0a3
Author: Cancai Cai <77189278+caican...@users.noreply.github.com>
AuthorDate: Mon Dec 9 14:51:25 2024 +0800

    [Improve][ClickhouseFile] ClickhouseFile Connector's rsync transmission 
supports specifying users (#8236)
---
 .../connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java
 
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java
index 478af2f664..793dd6cf15 100644
--- 
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java
+++ 
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java
@@ -97,7 +97,7 @@ public class RsyncFileTransfer implements FileTransfer {
             rsyncCommand.add("-e");
             rsyncCommand.add(sshParameter);
             rsyncCommand.add(sourcePath);
-            rsyncCommand.add(String.format("root@%s:%s", host, targetPath));
+            rsyncCommand.add(String.format("%s@%s:%s", user, host, 
targetPath));
             log.info("Generate rsync command: {}", String.join(" ", 
rsyncCommand));
             ProcessBuilder processBuilder =
                     new ProcessBuilder("bash", "-c", String.join(" ", 
rsyncCommand));