Skip to content

Commit c77bff0

Browse files
committed
fix review
1 parent 0499854 commit c77bff0

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed

polaris-common/polaris-metadata/pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,12 @@
2020
<artifactId>polaris-threadlocal</artifactId>
2121
<version>${project.version}</version>
2222
</dependency>
23+
<dependency>
24+
<groupId>com.alibaba</groupId>
25+
<artifactId>transmittable-thread-local</artifactId>
26+
<version>2.14.5</version>
27+
<optional>true</optional>
28+
</dependency>
2329
</dependencies>
2430

2531
</project>

polaris-common/polaris-metadata/src/main/java/com/tencent/polaris/metadata/core/manager/MetadataContextHolder.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import java.util.function.Consumer;
2121
import java.util.function.Supplier;
2222

23+
import com.alibaba.ttl.TransmittableThreadLocal;
2324
import com.tencent.polaris.logging.LoggerFactory;
2425
import org.slf4j.Logger;
2526

@@ -35,12 +36,10 @@ public class MetadataContextHolder {
3536
ThreadLocal<MetadataContext> tempThreadLocalContext;
3637
try {
3738
// the class name need to be excluded in maven shade plugin
38-
Class<?> clazz = Class.forName("com.alibaba.ttl.TransmittableThreadLocal");
39-
tempThreadLocalContext = (ThreadLocal<MetadataContext>) clazz.getDeclaredConstructor(new Class[0]).newInstance();
39+
Class.forName("com.alibaba.ttl.TransmittableThreadLocal");
40+
tempThreadLocalContext = new TransmittableThreadLocal<>();
4041
LOG.info("Use TransmittableThreadLocal for thread local context");
4142
} catch (Exception e) {
42-
LOG.debug("Failed to use TransmittableThreadLocal for thread local context, msg: {}", e.getMessage());
43-
LOG.info("Use standard ThreadLocal for thread local context");
4443
tempThreadLocalContext = new ThreadLocal<>();
4544
}
4645
THREAD_LOCAL_CONTEXT = tempThreadLocalContext;

0 commit comments

Comments
 (0)