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/b9e64da6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/b9e64da6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/b9e64da6 Branch: refs/heads/KYLIN-1112 Commit: b9e64da6434a2c163bcfd5066d411299763e1e6a Parents: 730739f Author: Li, Yang <yang...@ebay.com> Authored: Thu Oct 29 11:50:31 2015 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Thu Nov 5 09:53:15 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/b9e64da6/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/b9e64da6/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) {