diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheBeProxy.java b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheBeProxy.java
index d7e5eda333..cb30cbb576 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheBeProxy.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheBeProxy.java
@@ -53,7 +53,7 @@ public class CacheBeProxy extends CacheProxy {
         try {
             Future<InternalService.PCacheResponse> future = BackendServiceProxy.getInstance()
                     .updateCache(address, request);
-            InternalService.PCacheResponse response = future.get(timeoutMs, TimeUnit.MICROSECONDS);
+            InternalService.PCacheResponse response = future.get(timeoutMs, TimeUnit.MILLISECONDS);
             if (response.getStatus() == InternalService.PCacheStatus.CACHE_OK) {
                 status.setStatus(new Status(TStatusCode.OK, "CACHE_OK"));
             } else {
@@ -125,7 +125,7 @@ public class CacheBeProxy extends CacheProxy {
             request = request.toBuilder().setClearType(InternalService.PClearType.CLEAR_ALL).build();
             LOG.info("clear all backend cache, backendId {}", backend.getId());
             Future<InternalService.PCacheResponse> future = BackendServiceProxy.getInstance().clearCache(address, request);
-            InternalService.PCacheResponse response = future.get(timeoutMs, TimeUnit.MICROSECONDS);
+            InternalService.PCacheResponse response = future.get(timeoutMs, TimeUnit.MILLISECONDS);
             if (response.getStatus() == InternalService.PCacheStatus.CACHE_OK) {
                 status.setStatus(new Status(TStatusCode.OK, "CACHE_OK"));
                 return true;