fix: change JNI sink normal logs to debug level (#19758) (#19902)

Co-authored-by: Eric Fu <[email protected]>
risingwavelabs · Dec 24, 2024 · 6da5969 · 6da5969
1 parent a40fa8f
commit 6da5969
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/...ngwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterHandler.java b/...ngwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterHandler.java
@@ -44,6 +44,6 @@ public static void runJniSinkWriterThread(long requestRxPtr, long responseTxPtr)
         } catch (Throwable t) {
             sinkWriterStreamObserver.onError(t);
         }
-        LOG.info("end of runJniSinkWriterThread");
+        LOG.debug("end of runJniSinkWriterThread");
     }
 }
diff --git a/...nnector-service/src/main/java/com/risingwave/connector/JniSinkWriterResponseObserver.java b/...nnector-service/src/main/java/com/risingwave/connector/JniSinkWriterResponseObserver.java
@@ -51,7 +51,7 @@ public void onError(Throwable throwable) {
 
     @Override
     public void onCompleted() {
-        LOG.info("JniSinkWriterHandler onCompleted");
+        LOG.debug("JniSinkWriterHandler onCompleted");
     }
 
     public boolean isSuccess() {

diff --git a/...ve-connector-service/src/main/java/com/risingwave/connector/SinkWriterStreamObserver.java b/...ve-connector-service/src/main/java/com/risingwave/connector/SinkWriterStreamObserver.java
@@ -187,7 +187,7 @@ public void onError(Throwable throwable) {
 
     @Override
     public void onCompleted() {
-        LOG.info("sink writer completed");
+        LOG.debug("sink writer completed");
         cleanup();
         responseObserver.onCompleted();
     }

diff --git a/src/connector/src/sink/remote.rs b/src/connector/src/sink/remote.rs
@@ -782,7 +782,7 @@ impl EmbeddedConnectorClient {
 
                 match result {
                     Ok(_) => {
-                        tracing::info!("end of jni call {}::{}", class_name, method_name);
+                        tracing::debug!("end of jni call {}::{}", class_name, method_name);
                     }
                     Err(e) => {
                         tracing::error!(error = %e.as_report(), "jni call error");