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 <[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]
