Log message if file system caching is disabled on coordinator

Co-authored-by: Yuya Ebihara <[email protected]>
trinodb · Apr 29, 2024 · a0103b1 · a0103b1
1 parent fa86edb
commit a0103b1
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/lib/trino-filesystem-cache-alluxio/pom.xml b/lib/trino-filesystem-cache-alluxio/pom.xml
@@ -44,6 +44,11 @@
             <artifactId>configuration</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>io.airlift</groupId>
+            <artifactId>log</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>io.airlift</groupId>
             <artifactId>stats</artifactId>

diff --git a/...-alluxio/src/main/java/io/trino/filesystem/alluxio/AlluxioCoordinatorFileSystemCache.java b/...-alluxio/src/main/java/io/trino/filesystem/alluxio/AlluxioCoordinatorFileSystemCache.java
@@ -17,6 +17,7 @@
 import alluxio.conf.AlluxioProperties;
 import alluxio.conf.InstancedConfiguration;
 import com.google.inject.Inject;
+import io.airlift.log.Logger;
 import io.opentelemetry.api.trace.Tracer;
 import io.trino.filesystem.Location;
 import io.trino.filesystem.TrinoInput;
@@ -35,6 +36,8 @@
 public class AlluxioCoordinatorFileSystemCache
         implements TrinoFileSystemCache
 {
+    private static final Logger log = Logger.get(AlluxioCoordinatorFileSystemCache.class);
+
     private final Optional<AlluxioFileSystemCache> alluxioFileSystemCache;
 
     @Inject
@@ -49,6 +52,7 @@ public AlluxioCoordinatorFileSystemCache(
             alluxioFileSystemCache = Optional.of(new AlluxioFileSystemCache(tracer, config, statistics));
         }
         else {
+            log.debug("File system cache is disabled on a coordinator");
             alluxioFileSystemCache = Optional.empty();
             try {
                 CacheManager cacheManager = CacheManager.Factory.create(new InstancedConfiguration(new AlluxioProperties()));