[Improve][ClickhouseFile] Improve rsync log output (apache#8332)

TongchengOpenSource · Dec 19, 2024 · 179223e · 179223e
1 parent 19d5325
commit 179223e
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...ava/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java b/...ava/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/RsyncFileTransfer.java
@@ -108,7 +108,15 @@ public void transferAndChown(String sourcePath, String targetPath) {
                     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();