From 29a4ff4bbefd2359b0345275cf58d96c0708747a Mon Sep 17 00:00:00 2001 From: Lijia Liu Date: Wed, 27 Oct 2021 09:53:58 +0800 Subject: [PATCH] [Cache][Bug] Correct update cache timeout unit (#6888) Now FE update cache use MICROSECONDS as TimeUnit. Replace it by MILLISECONDS. --- .../src/main/java/org/apache/doris/qe/cache/CacheBeProxy.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 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 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;