[Enhancement] use info log for DefaultStreamLoader#close (StarRocks#243)

banmoy · banmoy · commit ac65bf59a36f · 2023-08-28T20:32:51.000+08:00
Signed-off-by: PengFei Li &lt;lpengfei2016@gmail.com&gt;
diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/DefaultStreamLoader.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/DefaultStreamLoader.java
@@ -99,7 +99,7 @@ protected boolean isRedirectable(String method) {
     public void close() {
         if (start.compareAndSet(true, false)) {
             executorService.shutdownNow();
-            log.warn("Default Stream loader closed");
+            log.info("Default Stream loader closed");
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -99,7 +99,7 @@ protected boolean isRedirectable(String method) {`
`99`	`99`	`public void close() {`
`100`	`100`	`if (start.compareAndSet(true, false)) {`
`101`	`101`	`executorService.shutdownNow();`
`102`		`- log.warn("Default Stream loader closed");`
	`102`	`+ log.info("Default Stream loader closed");`
`103`	`103`	`}`
`104`	`104`	`}`
`105`	`105`