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/27 08:09:51 UTC
incubator-lens git commit: LENS-424 : Fix logging in partition
timeline (Rajat Khandelwal via amareshwari)
Repository: incubator-lens
Updated Branches:
refs/heads/master b86424c8c -> e5bc9e9b7
LENS-424 : Fix logging in partition timeline (Rajat Khandelwal via 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/e5bc9e9b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-lens/tree/e5bc9e9b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-lens/diff/e5bc9e9b
Branch: refs/heads/master
Commit: e5bc9e9b791adf2e704bc3b0532ee0177ff8c69f
Parents: b86424c
Author: Rajat Khandelwal <pr...@apache.org>
Authored: Fri Mar 27 12:39:38 2015 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Fri Mar 27 12:39:38 2015 +0530
----------------------------------------------------------------------
.../java/org/apache/lens/cube/metadata/CubeMetastoreClient.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/e5bc9e9b/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 41b5b08..42bf98f 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
@@ -195,6 +195,7 @@ public class CubeMetastoreClient {
// Not found in table properties either, compute from all partitions of the fact-storage table.
// First make sure all combinations of update period and partition column have an entry even
// if no partitions exist
+ log.info("loading from all partitions");
if (getCubeFact(fact).getUpdatePeriods() != null && getCubeFact(fact).getUpdatePeriods().get(
storage) != null) {
for (UpdatePeriod updatePeriod : getCubeFact(fact).getUpdatePeriods().get(storage)) {
@@ -221,6 +222,7 @@ public class CubeMetastoreClient {
commitAllBatchAdditions(storageTableName);
} else {
// found in table properties, load from there.
+ log.info("loading from table properties");
for (UpdatePeriod updatePeriod : getCubeFact(fact).getUpdatePeriods().get(storage)) {
for (String partCol : getTimePartsOfTable(storageTableName)) {
ensureEntry(storageTableName, updatePeriod, partCol).init(storageTable);
@@ -277,7 +279,6 @@ public class CubeMetastoreClient {
CubeMetastoreClient.this, storageTable, updatePeriod, partitionColumn));
}
PartitionTimeline ret = get(storageTable).get(updatePeriod).get(partitionColumn);
- log.info("ensured entry " + ret);
return ret;
}