This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 52a599d13a4 Refactor MetaDataContextHolder (#34245)
52a599d13a4 is described below
commit 52a599d13a4f044ae3c950aac0ac1a4251dd8916
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Jan 4 17:53:57 2025 +0800
Refactor MetaDataContextHolder (#34245)
---
.../shardingsphere/mode/metadata/MetaDataContextHolder.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/MetaDataContextHolder.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/MetaDataContextHolder.java
index 9a8a86852e1..fe69035f9cd 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/MetaDataContextHolder.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/MetaDataContextHolder.java
@@ -17,18 +17,20 @@
package org.apache.shardingsphere.mode.metadata;
-import lombok.AllArgsConstructor;
import lombok.Getter;
+import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicReference;
/**
* Meta data context holder.
*/
-@AllArgsConstructor
+@RequiredArgsConstructor
@Slf4j
public final class MetaDataContextHolder {
@@ -44,8 +46,8 @@ public final class MetaDataContextHolder {
*/
public MetaDataContexts getMetaDataContextsAsync() {
try {
- return future.get(5, TimeUnit.SECONDS);
- } catch (final InterruptedException |
java.util.concurrent.ExecutionException | java.util.concurrent.TimeoutException
ex) {
+ return future.get(5L, TimeUnit.SECONDS);
+ } catch (final InterruptedException | ExecutionException |
TimeoutException ex) {
return metaDataContexts.get();
}
}