Repository: incubator-kylin Updated Branches: refs/heads/2.x-staging b64a0e998 -> cb94c8127
bug fix, SingleValueCache.put() should put local cache first Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/cb94c812 Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/cb94c812 Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/cb94c812 Branch: refs/heads/2.x-staging Commit: cb94c812707bc53b7d5da78f96f68e046400a29b Parents: b64a0e9 Author: Li, Yang <yang...@ebay.com> Authored: Thu Oct 29 11:50:31 2015 +0800 Committer: Li, Yang <yang...@ebay.com> Committed: Thu Oct 29 11:51:18 2015 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/common/restclient/SingleValueCache.java | 2 ++ .../src/main/java/org/apache/kylin/metadata/MetadataManager.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/cb94c812/core-common/src/main/java/org/apache/kylin/common/restclient/SingleValueCache.java ---------------------------------------------------------------------- diff --git a/core-common/src/main/java/org/apache/kylin/common/restclient/SingleValueCache.java b/core-common/src/main/java/org/apache/kylin/common/restclient/SingleValueCache.java index 50b0f84..2a3ff06 100644 --- a/core-common/src/main/java/org/apache/kylin/common/restclient/SingleValueCache.java +++ b/core-common/src/main/java/org/apache/kylin/common/restclient/SingleValueCache.java @@ -44,6 +44,8 @@ public abstract class SingleValueCache<K, V> extends AbstractRestCache<K, V> { public void put(K key, V value) { boolean exists = innerCache.containsKey(key); + + innerCache.put(key, value); if (!exists) { cacheUpdater.updateCache(key, value, Broadcaster.EVENT.CREATE, syncType, this); http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/cb94c812/core-metadata/src/main/java/org/apache/kylin/metadata/MetadataManager.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/MetadataManager.java b/core-metadata/src/main/java/org/apache/kylin/metadata/MetadataManager.java index 9b66578..b7e7dc5 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/MetadataManager.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/MetadataManager.java @@ -431,7 +431,7 @@ public class MetadataManager { os.close(); is.close(); - srcTableExdMap.putLocal(tableId, tableExdProperties); + srcTableExdMap.put(tableId, tableExdProperties); } public String appendDBName(String table) {
