[Improve][ClickhouseFile] Added attach sql log for better debugging (#8315)

Author: caicancai

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkAggCommitter.java

@@ -28,13 +28,15 @@
 import com.clickhouse.client.ClickHouseException;
 import com.clickhouse.client.ClickHouseRequest;
 import com.clickhouse.client.ClickHouseResponse;
+import lombok.extern.slf4j.Slf4j;
 
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+@Slf4j
 public class ClickhouseFileSinkAggCommitter
         implements SinkAggregatedCommitter<CKFileCommitInfo, CKFileAggCommitInfo> {
 
@@ -117,14 +119,15 @@ private void attachFileToClickhouse(Shard shard, List<String> clickhouseLocalFil
             throws ClickHouseException {
         ClickHouseRequest<?> request = getProxy().getClickhouseConnection(shard);
         for (String clickhouseLocalFile : clickhouseLocalFiles) {
-            ClickHouseResponse response =
-                    request.query(
-                                    String.format(
-                                            "ALTER TABLE %s ATTACH PART '%s'",
-                                            clickhouseTable.getLocalTableName(),
-                                            clickhouseLocalFile.substring(
-                                                    clickhouseLocalFile.lastIndexOf("/") + 1)))
-                            .executeAndWait();
+            String attachSql =
+                    String.format(
+                            "ALTER TABLE %s ATTACH PART '%s'",
+                            clickhouseTable.getLocalTableName(),
+                            clickhouseLocalFile.substring(
+                                    clickhouseLocalFile.lastIndexOf("/") + 1));
+
+            log.info("Attach file to clickhouse table: {}", attachSql);
+            ClickHouseResponse response = request.query(attachSql).executeAndWait();
             response.close();
         }
     }