fix config query notify delay (#13050)

* fix type search on mysql model * 灰度模型迁移程序并发&迁移不落历史表 * fix notify delay
alibaba · Jan 17, 2025 · 90d3469 · 90d3469
1 parent 2d78d1c
commit 90d3469
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/config/src/main/java/com/alibaba/nacos/config/server/controller/ConfigServletInner.java b/config/src/main/java/com/alibaba/nacos/config/server/controller/ConfigServletInner.java
@@ -291,7 +291,7 @@ private void logPullEvent(String dataId, String group, String tenant, String req
             ConfigTraceService.logPullEvent(dataId, group, tenant, requestIpApp, -1, pullEvent,
                     ConfigTraceService.PULL_TYPE_NOTFOUND, -1, clientIp, notify, "http");
         } else {
-            long delayed = notify ? -1 : System.currentTimeMillis() - chainResponse.getLastModified();
+            long delayed = System.currentTimeMillis() - chainResponse.getLastModified();
             ConfigTraceService.logPullEvent(dataId, group, tenant, requestIpApp, chainResponse.getLastModified(),
                     pullEvent, ConfigTraceService.PULL_TYPE_OK, delayed, clientIp, notify, "http");
         }

diff --git a/config/src/main/java/com/alibaba/nacos/config/server/remote/ConfigQueryRequestHandler.java b/config/src/main/java/com/alibaba/nacos/config/server/remote/ConfigQueryRequestHandler.java
@@ -127,7 +127,7 @@ public ConfigQueryResponse handle(ConfigQueryRequest request, RequestMeta meta)
 
             String pullEvent = resolvePullEventType(chainResponse, request.getTag());
             LogUtil.PULL_CHECK_LOG.warn("{}|{}|{}|{}", groupKey, clientIp, response.getMd5(), TimeUtils.getCurrentTimeStr());
-            final long delayed = notify ? -1 : System.currentTimeMillis() - response.getLastModified();
+            final long delayed = System.currentTimeMillis() - response.getLastModified();
             ConfigTraceService.logPullEvent(dataId, group, tenant, requestIpApp, response.getLastModified(), pullEvent, pullType,
                     delayed, clientIp, notify, "grpc");