(kudu) branch master updated: [java] add sequenceId into the tracked RPCs' trace

[alexey]

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

alexey pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kudu.git


The following commit(s) were added to refs/heads/master by this push:
     new b88e3e9e4 [java] add sequenceId into the tracked RPCs' trace
b88e3e9e4 is described below

commit b88e3e9e46aaa710d7c32558a1aa355d0bee7913
Author: Alexey Serbin <ale...@apache.org>
AuthorDate: Thu Jan 4 09:48:17 2024 -0800

    [java] add sequenceId into the tracked RPCs' trace
    
    This patch adds sequenceId into the result of KuduRpc.ToString() for
    tracked RPCs (i.e. Write RPC as of now).  That's to provide better
    tracking of retries performed in the context of exactly-once semantics.
    I found this information would be helpful when troubleshooting
    particular scenarios.
    
    Otherwise, there are no functional modifications in this changelist.
    
    Change-Id: I55bd45f13b406a5aad7532f3a449a7c670d9f09d
    Reviewed-on: http://gerrit.cloudera.org:8080/20857
    Reviewed-by: Abhishek Chennaka <achenn...@cloudera.com>
    Tested-by: Kudu Jenkins
---
 java/kudu-client/src/main/java/org/apache/kudu/client/KuduRpc.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/KuduRpc.java 
b/java/kudu-client/src/main/java/org/apache/kudu/client/KuduRpc.java
index 095a9a0b6..3aac537bc 100644
--- a/java/kudu-client/src/main/java/org/apache/kudu/client/KuduRpc.java
+++ b/java/kudu-client/src/main/java/org/apache/kudu/client/KuduRpc.java
@@ -397,6 +397,9 @@ public abstract class KuduRpc<R> {
       buf.append(tablet.getTabletId());
     }
     buf.append(", attempt=").append(attempt);
+    if (isRequestTracked()) {
+      buf.append(", sequence_id=").append(sequenceId);
+    }
     buf.append(", ").append(timeoutTracker);
     // Cheating a bit, we're not actually logging but we'll augment the 
information provided by
     // this method if DEBUG is enabled.