You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2015/11/05 02:54:18 UTC

[04/31] incubator-kylin git commit: bug fix, SingleValueCache.put() should put local cache first

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 <ya...@ebay.com>
Authored: Thu Oct 29 11:50:31 2015 +0800
Committer: shaofengshi <sh...@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) {