From 81c0cca110127abbd268c3b8bc93a335b4d56b13 Mon Sep 17 00:00:00 2001
From: liaozan <378024053@qq.com>
Date: Tue, 12 Dec 2023 16:20:39 +0800
Subject: [PATCH] Add log for starrocks

---
 .../operation/StarrocksStreamLoadHandler.java       | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

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 b151c76..6a92557 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);
     }
-- 
GitLab