This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 716cafa748 [INLONG-8633][SDK] Update debug log level (#8634)
716cafa748 is described below
commit 716cafa748b1f0028e730432ae6cf42ddf8c532b
Author: gunli <[email protected]>
AuthorDate: Mon Aug 7 10:51:21 2023 +0800
[INLONG-8633][SDK] Update debug log level (#8634)
---
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go | 2 +-
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/logger/logger.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go
b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go
index eb4a8348ac..be3772c38d 100755
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go
@@ -585,7 +585,7 @@ func (w *worker) handleRsp(rsp batchRsp) {
batchID := rsp.batchID
batch, ok := w.unackedBatches[batchID]
if !ok {
- w.log.Warn("worker[", w.index, "] batch not found in
unackedBatches map:", batchID, ", send time:", rsp.dt, ", now:",
time.Now().UnixMilli())
+ w.log.Debug("worker[", w.index, "] batch not found in
unackedBatches map:", batchID, ", send time:", rsp.dt, ", now:",
time.Now().UnixMilli())
w.metrics.incError(errNoMatchReq4Rsp.strCode)
return
}
diff --git
a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/logger/logger.go
b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/logger/logger.go
index 921ee9f228..46b7753134 100755
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/logger/logger.go
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/logger/logger.go
@@ -42,7 +42,7 @@ type stdLogger struct {
}
func (s stdLogger) Debug(args ...interface{}) {
- fmt.Println(args...)
+ // fmt.Println(args...)
}
func (s stdLogger) Info(args ...interface{}) {
