diff --git a/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/operation/StarrocksStreamLoadHandler.java b/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/operation/StarrocksStreamLoadHandler.java
index b151c7682ea1b5ec2bf54957bf78912bf8f128cd..6a92557cfb47d15927cb4f3998f8b88c07c88b8f 100644
--- a/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/operation/StarrocksStreamLoadHandler.java
+++ b/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/operation/StarrocksStreamLoadHandler.java
@@ -28,17 +28,26 @@ public class StarrocksStreamLoadHandler {
     }
 
     public <T> void upsertBatch(List<T> entityList, List<String> columns) {
+        log.info("Starrocks upsert, dataSize: {}, sample data: {}", entityList.size(), entityList.get(0));
+
         String content = JacksonUtils.toJsonString(entityList);
         String upsertResult = createUpsertRequest(content, columns).execute().body();
-        log.debug("Starrocks streamLoad upsert result: {}", upsertResult);
+
+        if (log.isDebugEnabled()) {
+            log.debug("Starrocks streamLoad upsert result: {}", upsertResult);
+        }
 
         checkResponse(upsertResult);
     }
 
     public <T> void deleteBatch(List<T> entityList) {
+        log.info("Starrocks delete, dataSize: {}, sample data: {}", entityList.size(), entityList.get(0));
         String content = JacksonUtils.toJsonString(entityList);
         String deleteResult = createCommonRequest(content).header("columns", "__op='delete'").execute().body();
-        log.debug("Starrocks streamLoad delete result: {}", deleteResult);
+
+        if (log.isDebugEnabled()) {
+            log.debug("Starrocks streamLoad delete result: {}", deleteResult);
+        }
 
         checkResponse(deleteResult);
     }