You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/10/29 06:09:25 UTC
incubator-kylin git commit: bug fix,
SingleValueCache.put() should put local cache first
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 <ya...@ebay.com>
Authored: Thu Oct 29 11:50:31 2015 +0800
Committer: Li, Yang <ya...@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) {