[incubator-inlong] branch master updated: [INGLONG-2756][agent]Add more logs when sending data to proxy #2756 (#2757)

[go...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new c5b3c19  [INGLONG-2756][agent]Add more logs when sending data to proxy #2756 (#2757)
c5b3c19 is described below

commit c5b3c19a0918a93871d08a3e27de22385654467f
Author: ziruipeng <zp...@connect.ust.hk>
AuthorDate: Sun Feb 27 11:02:48 2022 +0800

    [INGLONG-2756][agent]Add more logs when sending data to proxy #2756 (#2757)
---
 .../main/java/org/apache/inlong/agent/plugin/sinks/SenderManager.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/SenderManager.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/SenderManager.java
index 9f9b59e..82d8de9 100755
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/SenderManager.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/SenderManager.java
@@ -199,8 +199,8 @@ public class SenderManager {
         public void onMessageAck(SendResult result) {
             // if send result is not ok, retry again.
             if (result == null || !result.equals(SendResult.OK)) {
-                LOGGER.warn("send groupId {}, streamId {}, jobId {}, dataTime {} fail with times {}",
-                    groupId, streamId, jobId, dataTime, retry);
+                LOGGER.warn("send groupId {}, streamId {}, jobId {}, dataTime {} fail with times {}, "
+                        + "error {}", groupId, streamId, jobId, dataTime, retry, result);
                 sendBatch(jobId, groupId, streamId, bodyList, retry + 1, dataTime);
                 return;
             }