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";