Details
diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutionFlowDao.java b/azkaban-common/src/main/java/azkaban/executor/ExecutionFlowDao.java
index dd829e3..9bd4945 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutionFlowDao.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutionFlowDao.java
@@ -138,7 +138,7 @@ public class ExecutionFlowDao {
}
}
- public static APLCache<List<ExecutableFlow>> fetchRecentlyFinishedFlowsCache = new APLCache<>("ExecutionFlowDao.fetchRecentlyFinishedFlows");
+ public static APLCache<List<ExecutableFlow>> fetchRecentlyFinishedFlowsCache = new APLCache<>("static-multi:ExecutionFlowDao.fetchRecentlyFinishedFlows");
List<ExecutableFlow> fetchRecentlyFinishedFlows(final Duration maxAge)
throws ExecutorManagerException {
diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
index 7438321..f8f3a33 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
@@ -597,7 +597,7 @@ public class ExecutorManager extends EventHandler implements
}
}
-public static GetterCache<List<ExecutableFlow>> getRecentlyFinishedFlowsCache = new GetterCache<>("ExecutorManager.getRecentlyFinishedFlows");
+public static GetterCache<List<ExecutableFlow>> getRecentlyFinishedFlowsCache = new GetterCache<>("static-getter:ExecutorManager.getRecentlyFinishedFlows");
@Override
public List<ExecutableFlow> getRecentlyFinishedFlows() {
diff --git a/azkaban-common/src/main/java/azkaban/executor/JdbcExecutorLoader.java b/azkaban-common/src/main/java/azkaban/executor/JdbcExecutorLoader.java
index ac48e36..5f31b1b 100644
--- a/azkaban-common/src/main/java/azkaban/executor/JdbcExecutorLoader.java
+++ b/azkaban-common/src/main/java/azkaban/executor/JdbcExecutorLoader.java
@@ -89,7 +89,7 @@ public class JdbcExecutorLoader implements ExecutorLoader {
return this.executionFlowDao.fetchQueuedFlows();
}
- public static APLCache<List<ExecutableFlow>> fetchRecentlyFinishedFlowsCache = new APLCache<>("JdbcExecutorLoader.fetchRecentlyFinishedFlows");
+ public static APLCache<List<ExecutableFlow>> fetchRecentlyFinishedFlowsCache = new APLCache<>("static-multi:JdbcExecutorLoader.fetchRecentlyFinishedFlows");
/**
* maxAge indicates how long finished flows are shown in Recently Finished flow page.
diff --git a/azkaban-common/src/main/java/azkaban/project/JdbcProjectImpl.java b/azkaban-common/src/main/java/azkaban/project/JdbcProjectImpl.java
index eec3a67..64e700a 100644
--- a/azkaban-common/src/main/java/azkaban/project/JdbcProjectImpl.java
+++ b/azkaban-common/src/main/java/azkaban/project/JdbcProjectImpl.java
@@ -182,7 +182,7 @@ public class JdbcProjectImpl implements ProjectLoader {
return project;
}
- public static APLCache<List<Triple<String, Boolean, Permission>>> fetchPermissionsForProjectCache = new APLCache<>("JdbcProjectImpl.fetchPermissionsForProject");
+ public static APLCache<List<Triple<String, Boolean, Permission>>> fetchPermissionsForProjectCache = new APLCache<>("static-multi:JdbcProjectImpl.fetchPermissionsForProject");
private List<Triple<String, Boolean, Permission>> fetchPermissionsForProject(
final Project project)
diff --git a/azkaban-common/src/main/java/azkaban/project/ProjectManager.java b/azkaban-common/src/main/java/azkaban/project/ProjectManager.java
index 4e5c486..7c43370 100644
--- a/azkaban-common/src/main/java/azkaban/project/ProjectManager.java
+++ b/azkaban-common/src/main/java/azkaban/project/ProjectManager.java
@@ -166,7 +166,7 @@ public class ProjectManager {
return array;
}
- public static APLCache<List<Project>> getGroupProjectsCache = new APLCache<>("ProjectManager.getGroupProjects");
+ public static APLCache<List<Project>> getGroupProjectsCache = new APLCache<>("static-multi:ProjectManager.getGroupProjects");
public List<Project> getGroupProjects(final User user) {
return getGroupProjectsCache.computeIfAbsent(Thread.currentThread(), new Object[]{user}, () -> {
diff --git a/azkaban-common/src/main/java/azkaban/utils/StringUtils.java b/azkaban-common/src/main/java/azkaban/utils/StringUtils.java
index bcdb9c2..7e8b0ba 100644
--- a/azkaban-common/src/main/java/azkaban/utils/StringUtils.java
+++ b/azkaban-common/src/main/java/azkaban/utils/StringUtils.java
@@ -89,7 +89,7 @@ public class StringUtils {
return buffer.toString();
}
- public static APLCache<Boolean> isFromBrowserCache = new APLCache<>("StringUtils.isFromBrowser");
+ public static APLCache<Boolean> isFromBrowserCache = new APLCache<>("static-multi:StringUtils.isFromBrowser");
public static boolean isFromBrowser(final String userAgent) {
return isFromBrowserCache.computeIfAbsent(Thread.currentThread(), new Object[]{userAgent}, () -> {