From 09486d85326b384f4397599ec7d40b47433539ee Mon Sep 17 00:00:00 2001
From: Eric Fu <eric@singularity-data.com>
Date: Wed, 11 Dec 2024 16:07:34 +0800
Subject: [PATCH] chore: change verbose logs to debug level

---
 .../java/com/risingwave/connector/JniSinkWriterHandler.java     | 2 +-
 .../com/risingwave/connector/JniSinkWriterResponseObserver.java | 2 +-
 .../java/com/risingwave/connector/SinkWriterStreamObserver.java | 2 +-
 src/connector/src/sink/remote.rs                                | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterHandler.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterHandler.java
index 89bd1dd7e6865..604463e578985 100644
--- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterHandler.java
+++ b/java/connector-node/risingwave-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/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterResponseObserver.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterResponseObserver.java
index 1f1c68f54551e..505a22947b655 100644
--- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterResponseObserver.java
+++ b/java/connector-node/risingwave-connector-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/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkWriterStreamObserver.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkWriterStreamObserver.java
index 53dfe326fbd9d..55e5befa62ea6 100644
--- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkWriterStreamObserver.java
+++ b/java/connector-node/risingwave-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
index 76e65418cdf18..e9b00a1a63e4f 100644
--- 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");