(fluss) branch main updated: [hotfix] Add debug log for NettyServerHandler to trace the request process time (#1720)

[yunhong]

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

yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 69ba18ee2 [hotfix] Add debug log for NettyServerHandler to trace the 
request process time (#1720)
69ba18ee2 is described below

commit 69ba18ee261fac5dc2af6961e7b59ef2516e1d69
Author: yunhong <337361...@qq.com>
AuthorDate: Fri Sep 19 10:36:08 2025 +0800

    [hotfix] Add debug log for NettyServerHandler to trace the request process 
time (#1720)
---
 .../org/apache/fluss/rpc/netty/server/NettyServerHandler.java     | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/fluss-rpc/src/main/java/org/apache/fluss/rpc/netty/server/NettyServerHandler.java
 
b/fluss-rpc/src/main/java/org/apache/fluss/rpc/netty/server/NettyServerHandler.java
index 3080c87e0..ff0777712 100644
--- 
a/fluss-rpc/src/main/java/org/apache/fluss/rpc/netty/server/NettyServerHandler.java
+++ 
b/fluss-rpc/src/main/java/org/apache/fluss/rpc/netty/server/NettyServerHandler.java
@@ -240,6 +240,14 @@ public final class NettyServerHandler extends 
ChannelInboundHandlerAdapter {
             send.writeTo(ctx);
             ctx.flush();
             long requestEndTimeMs = System.currentTimeMillis();
+            LOG.debug(
+                    "Finished process request type: {}, inQueueTime: {}, 
processTime: {}, "
+                            + "responseSendToClientTime: {}, request from: {}",
+                    request.getApiMethod().getApiKey(),
+                    request.getRequestDequeTimeMs() - request.getStartTimeMs(),
+                    request.getRequestCompletedTimeMs() - 
request.getRequestDequeTimeMs(),
+                    requestEndTimeMs - request.getRequestCompletedTimeMs(),
+                    request.getAddress());
             updateRequestMetrics(request, requestEndTimeMs);
         } catch (Throwable t) {
             LOG.error("Failed to send response to client.", t);