(seatunnel) branch dev updated: [Improve][ClickhouseFile] Improve rsync log output (#8332)

[fanjia]

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

fanjia 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 179223e3c2 [Improve][ClickhouseFile] Improve rsync log output (#8332)
179223e3c2 is described below

commit 179223e3c2bc523dcf938d7b708fdd8d91d1a2aa
Author: Cancai Cai <77189278+caican...@users.noreply.github.com>
AuthorDate: Thu Dec 19 10:11:25 2024 +0800

    [Improve][ClickhouseFile] Improve rsync log output (#8332)
---
 .../seatunnel/clickhouse/sink/file/RsyncFileTransfer.java      | 10 +++++++++-
 1 file changed, 9 insertions(+), 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 793dd6cf15..70d217069b 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
@@ -108,7 +108,15 @@ public class RsyncFileTransfer implements FileTransfer {
                     BufferedReader bufferedReader = new 
BufferedReader(inputStreamReader)) {
                 String line;
                 while ((line = bufferedReader.readLine()) != null) {
-                    log.info(line);
+                    log.info("rsync output: {}", line);
+                }
+            }
+            try (InputStream errorStream = start.getErrorStream();
+                    InputStreamReader errorStreamReader = new 
InputStreamReader(errorStream);
+                    BufferedReader bufferedReader = new 
BufferedReader(errorStreamReader)) {
+                String line;
+                while ((line = bufferedReader.readLine()) != null) {
+                    log.error("rsync error: {}", line);
                 }
             }
             start.waitFor();