[incubator-doris] branch master updated: [Cache][Bug] Correct update cache timeout unit (#6888)

[morningman]

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

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 29a4ff4  [Cache][Bug] Correct update cache timeout unit (#6888)
29a4ff4 is described below

commit 29a4ff4bbefd2359b0345275cf58d96c0708747a
Author: Lijia Liu <liutang...@yeah.net>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org