This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-0.15 in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit 4bb24d2488482e8b76c3d94b99ffb82b6007c43b Author: Lijia Liu <[email protected]> AuthorDate: Wed Oct 27 09:53:58 2021 +0800 [Cache][Bug] Correct update cache timeout unit (#6888) Now FE update cache use MICROSECONDS as TimeUnit. Replace it by MILLISECONDS. --- fe/fe-core/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 d7e5eda..cb30cbb 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; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
