azkaban-aplcache

Details

diff --git a/azkaban-common/src/main/java/azkaban/project/ProjectManager.java b/azkaban-common/src/main/java/azkaban/project/ProjectManager.java
index c9df778..89e3f6a 100644
--- a/azkaban-common/src/main/java/azkaban/project/ProjectManager.java
+++ b/azkaban-common/src/main/java/azkaban/project/ProjectManager.java
@@ -213,6 +213,7 @@ public class ProjectManager {
       fetchedProject = this.projectsByName.get(name);
     } else {
       try {
+        logger.info("Project " + name + " doesn't exist in cache, fetching from DB now.");
         fetchedProject = this.projectLoader.fetchProjectByName(name);
       } catch (final ProjectManagerException e) {
         logger.error("Could not load project from store.", e);
diff --git a/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java b/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java
index c893b51..f7103ef 100644
--- a/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java
+++ b/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java
@@ -1295,6 +1295,8 @@ public class ProjectManagerServlet extends LoginAbstractAzkabanServlet {
     Flow flow = null;
     try {
       project = this.projectManager.getProject(projectName);
+      logger.info("JobPage: project " + projectName + " version is " + project.getVersion()
+          + ", reference is " + System.identityHashCode(project));
       if (project == null) {
         page.add("errorMsg", "Project " + projectName + " not found.");
         page.render();
@@ -1644,6 +1646,9 @@ public class ProjectManagerServlet extends LoginAbstractAzkabanServlet {
     final User user = session.getUser();
     final String projectName = (String) multipart.get("project");
     final Project project = this.projectManager.getProject(projectName);
+    logger.info(
+        "Upload: reference of project " + projectName + " is " + System.identityHashCode(project));
+
     final String autoFix = (String) multipart.get("fix");
     final Props props = new Props();
     if (autoFix != null && autoFix.equals("off")) {
@@ -1764,6 +1769,8 @@ public class ProjectManagerServlet extends LoginAbstractAzkabanServlet {
         }
       }
 
+      logger.info("Upload: project " + projectName + " version is " + project.getVersion()
+          + ", reference is " + System.identityHashCode(project));
       ret.put("version", String.valueOf(project.getVersion()));
     }
   }
diff --git a/azkaban-web-server/src/restli/java/azkaban/restli/ProjectManagerResource.java b/azkaban-web-server/src/restli/java/azkaban/restli/ProjectManagerResource.java
index 1db7c34..b2d2575 100644
--- a/azkaban-web-server/src/restli/java/azkaban/restli/ProjectManagerResource.java
+++ b/azkaban-web-server/src/restli/java/azkaban/restli/ProjectManagerResource.java
@@ -62,6 +62,8 @@ public class ProjectManagerResource extends ResourceContextHolder {
     final User user = ResourceUtils.getUserFromSessionId(sessionId);
     final ProjectManager projectManager = getAzkaban().getProjectManager();
     final Project project = projectManager.getProject(projectName);
+    logger.info("Deploy: reference of project " + projectName + " is " + System.identityHashCode
+        (project));
     if (project == null) {
       final String errorMsg = "Project '" + projectName + "' not found.";
       throw new RestLiServiceException(HttpStatus.S_400_BAD_REQUEST, errorMsg);
@@ -115,6 +117,8 @@ public class ProjectManagerResource extends ResourceContextHolder {
       final Map<String, ValidationReport> reports = projectManager
           .uploadProject(project, archiveFile, "zip", user, props);
       checkReports(reports);
+      logger.info("Deploy: project " + projectName + " version is " + project.getVersion()
+          + ", reference is " + System.identityHashCode(project));
       return Integer.toString(project.getVersion());
     } catch (final ProjectManagerException e) {
       final String errorMsg = "Upload of project " + project + " from " + archiveFile + " failed";