[incubator-paimon] branch master updated: [hotfix] Set directExecutor to caffeine Cache

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 97629c934 [hotfix] Set directExecutor to caffeine Cache
97629c934 is described below

commit 97629c934c344d53e69a2337fdf74964cc60256d
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Mon Apr 10 14:51:55 2023 +0800

    [hotfix] Set directExecutor to caffeine Cache
---
 paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java | 2 ++
 .../src/main/java/org/apache/paimon/io/cache/CacheManager.java          | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java 
b/paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java
index 6bfc1c38d..e13248a92 100644
--- a/paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java
+++ b/paimon-common/src/main/java/org/apache/paimon/codegen/CompileUtils.java
@@ -20,6 +20,7 @@ package org.apache.paimon.codegen;
 
 import 
org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache;
 import 
org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Caffeine;
+import 
org.apache.paimon.shade.guava30.com.google.common.util.concurrent.MoreExecutors;
 
 import org.codehaus.janino.SimpleCompiler;
 import org.slf4j.Logger;
@@ -50,6 +51,7 @@ public final class CompileUtils {
                     // estimated cache size
                     .maximumSize(300)
                     .softValues()
+                    .executor(MoreExecutors.directExecutor())
                     .build();
 
     /**
diff --git 
a/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java 
b/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java
index 7e758b445..052bda09f 100644
--- a/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java
+++ b/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java
@@ -24,6 +24,7 @@ import org.apache.paimon.options.MemorySize;
 import 
org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache;
 import 
org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Caffeine;
 import 
org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.RemovalCause;
+import 
org.apache.paimon.shade.guava30.com.google.common.util.concurrent.MoreExecutors;
 
 import java.io.IOException;
 import java.io.RandomAccessFile;
@@ -43,6 +44,7 @@ public class CacheManager {
                         .weigher(this::weigh)
                         .maximumWeight(maxMemorySize.getBytes())
                         .removalListener(this::onRemoval)
+                        .executor(MoreExecutors.directExecutor())
                         .build();
     }