database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Cache][Bug] Correct update cache timeout unit (#6888)

Browse Source 
Now FE update cache use MICROSECONDS as TimeUnit.
Replace it by MILLISECONDS.
This commit is contained in:
Lijia Liu
2021-10-27 09:53:58 +08:00
committed by GitHub
parent 4f9b46d403
commit 29a4ff4bbe
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheBeProxy.java vendored
View File

@ -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;