@@ -33,11 +33,11 @@ private static void loadConfig() {
3333 queryMaxEntries = getConfigInt (config , "planner.query.cache.max_entries_amount" , 100 );
3434 queryTtlMinutes = getConfigInt (config , "planner.query.cache.plan_cache_ttl_minutes" , 300 );
3535 transformMaxEntries = getConfigInt (config , "planner.transform.cache.max_entries_amount" , 100 );
36- transformTtlMinutes = getConfigInt (config , "planner.transform.plan_cache_ttl_minutes" , 300 );
36+ transformTtlMinutes = getConfigInt (config , "planner.transform.cache. plan_cache_ttl_minutes" , 300 );
3737
3838 queryCache = Caffeine .newBuilder ()
3939 .maximumSize (queryMaxEntries )
40- .expireAfterWrite (queryTtlMinutes , TimeUnit .MILLISECONDS )
40+ .expireAfterWrite (queryTtlMinutes , TimeUnit .MINUTES )
4141 .recordStats ()
4242 .build ();
4343
@@ -49,7 +49,15 @@ private static void loadConfig() {
4949 }
5050
5151 private static int getConfigInt (DrillConfig config , String path , int defaultValue ) {
52- return config .hasPath (path ) ? config .getInt (path ) : defaultValue ;
52+ logger .info ("Fetching: " + path );
53+ Boolean pathFound = config .hasPath (path );
54+ int value = pathFound ? config .getInt (path ) : defaultValue ;
55+ if (!pathFound ) {
56+ logger .info ("Using default value: " + defaultValue );
57+ } else {
58+ logger .info ("Using found value: " + value );
59+ }
60+ return value ;
5361 }
5462
5563 public static PhysicalPlan getQueryPlan (String sql ) {
0 commit comments