Repository: incubator-kylin Updated Branches: refs/heads/0.8.0 cf25daaf9 -> 49362dd14
ci fix: synchronize on project update Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/49362dd1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/49362dd1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/49362dd1 Branch: refs/heads/0.8.0 Commit: 49362dd1403db640b7809944bd302ccde756cc55 Parents: 341cda0 Author: honma <ho...@ebay.com> Authored: Fri May 29 10:52:31 2015 +0800 Committer: honma <ho...@ebay.com> Committed: Fri May 29 15:44:25 2015 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/metadata/project/ProjectManager.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/49362dd1/metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java ---------------------------------------------------------------------- diff --git a/metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java b/metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java index bcafcc7..dd146d9 100644 --- a/metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java +++ b/metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java @@ -19,7 +19,6 @@ package org.apache.kylin.metadata.project; import com.google.common.collect.Lists; -import org.apache.commons.lang3.StringUtils; import org.apache.kylin.common.KylinConfig; import org.apache.kylin.common.persistence.JsonSerializer; import org.apache.kylin.common.persistence.ResourceStore; @@ -225,9 +224,11 @@ public class ProjectManager { } private void updateProject(ProjectInstance prj) throws IOException { - getStore().putResource(prj.getResourcePath(), prj, PROJECT_SERIALIZER); - projectMap.put(norm(prj.getName()), prj); // triggers update broadcast - clearL2Cache(); + synchronized (prj) { + getStore().putResource(prj.getResourcePath(), prj, PROJECT_SERIALIZER); + projectMap.put(norm(prj.getName()), prj); // triggers update broadcast + clearL2Cache(); + } } private void removeProject(ProjectInstance proj) throws IOException {