(fluss) branch main updated: [server] Add DEBUG log for Coordinator event processing (#1296)

[jark]

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

jark 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 785244c1 [server] Add DEBUG log for Coordinator event processing 
(#1296)
785244c1 is described below

commit 785244c169762e3b2212aeb112a0808f741d06cd
Author: xiaozhou <whenzhou...@alibaba-inc.com>
AuthorDate: Sat Jul 12 15:32:04 2025 +0800

    [server] Add DEBUG log for Coordinator event processing (#1296)
---
 .../coordinator/event/CoordinatorEventManager.java     | 18 ++++++++++++++++--
 1 file changed, 16 insertions(+), 2 deletions(-)

diff --git 
a/fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CoordinatorEventManager.java
 
b/fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CoordinatorEventManager.java
index 1ecaf8da..addc21f8 100644
--- 
a/fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CoordinatorEventManager.java
+++ 
b/fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/event/CoordinatorEventManager.java
@@ -101,6 +101,11 @@ public final class CoordinatorEventManager implements 
EventManager {
                         QueuedEvent queuedEvent =
                                 new QueuedEvent(event, 
System.currentTimeMillis());
                         queue.put(queuedEvent);
+
+                        LOG.debug(
+                                "Put coordinator event {} of event type {}.",
+                                event,
+                                event.getClass());
                     } catch (InterruptedException e) {
                         LOG.error("Fail to put coordinator event {}.", event, 
e);
                     }
@@ -129,6 +134,10 @@ public final class CoordinatorEventManager implements 
EventManager {
 
             long eventStartTimeMs = System.currentTimeMillis();
 
+            LOG.debug(
+                    "Start processing event {} of event type {}.",
+                    coordinatorEvent,
+                    coordinatorEvent.getClass());
             try {
                 if (!(coordinatorEvent instanceof ShutdownEventThreadEvent)) {
                     eventQueueTime.update(System.currentTimeMillis() - 
queuedEvent.enqueueTimeMs);
@@ -137,8 +146,13 @@ public final class CoordinatorEventManager implements 
EventManager {
             } catch (Throwable e) {
                 log.error("Uncaught error processing event {}.", 
coordinatorEvent, e);
             } finally {
-                long eventFinishTimeMs = System.currentTimeMillis();
-                eventProcessingTime.update(eventFinishTimeMs - 
eventStartTimeMs);
+                long costTimeMs = System.currentTimeMillis() - 
eventStartTimeMs;
+                eventProcessingTime.update(costTimeMs);
+                LOG.debug(
+                        "Finished processing event {} of event type {} in 
{}ms.",
+                        coordinatorEvent,
+                        coordinatorEvent.getClass(),
+                        costTimeMs);
             }
         }
     }