You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by am...@apache.org on 2015/03/25 08:19:08 UTC
incubator-lens git commit: LENS-439 : Fix synchronization bug wrt get
methods on CubeMetastoreClient (amareshwari)
Repository: incubator-lens
Updated Branches:
refs/heads/master 1b811def3 -> 057872b3b
LENS-439 : Fix synchronization bug wrt get methods on CubeMetastoreClient (amareshwari)
Project: http://git-wip-us.apache.org/repos/asf/incubator-lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-lens/commit/057872b3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-lens/tree/057872b3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-lens/diff/057872b3
Branch: refs/heads/master
Commit: 057872b3b3780c221c667eccbf3188f253087970
Parents: 1b811de
Author: Amareshwari Sriramadasu <am...@apache.org>
Authored: Wed Mar 25 12:48:58 2015 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Wed Mar 25 12:48:58 2015 +0530
----------------------------------------------------------------------
.../apache/lens/cube/metadata/CubeMetastoreClient.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/057872b3/lens-cube/src/main/java/org/apache/lens/cube/metadata/CubeMetastoreClient.java
----------------------------------------------------------------------
diff --git a/lens-cube/src/main/java/org/apache/lens/cube/metadata/CubeMetastoreClient.java b/lens-cube/src/main/java/org/apache/lens/cube/metadata/CubeMetastoreClient.java
index 8758986..41b5b08 100644
--- a/lens-cube/src/main/java/org/apache/lens/cube/metadata/CubeMetastoreClient.java
+++ b/lens-cube/src/main/java/org/apache/lens/cube/metadata/CubeMetastoreClient.java
@@ -1093,6 +1093,8 @@ public class CubeMetastoreClient {
if (enableCaching) {
allHiveTables.put(tableName, tbl);
}
+ } else {
+ tbl = allHiveTables.get(tableName);
}
}
}
@@ -1294,6 +1296,8 @@ public class CubeMetastoreClient {
}
}
}
+ } else {
+ dimTable = allDimTables.get(tableName);
}
}
}
@@ -1324,6 +1328,8 @@ public class CubeMetastoreClient {
allStorages.put(storageName, storage);
}
}
+ } else {
+ storage = allStorages.get(storageName);
}
}
}
@@ -1354,6 +1360,8 @@ public class CubeMetastoreClient {
allCubes.put(tableName, cube);
}
}
+ } else {
+ cube = allCubes.get(tableName);
}
}
}
@@ -1380,6 +1388,8 @@ public class CubeMetastoreClient {
allDims.put(tableName, dim);
}
}
+ } else {
+ dim = allDims.get(tableName);
}
}
}
@@ -1403,6 +1413,8 @@ public class CubeMetastoreClient {
if (enableCaching && fact != null) {
allFactTables.put(tableName, fact);
}
+ } else {
+ fact = allFactTables.get(tableName);
}
}
}