Repository: lens Updated Branches: refs/heads/current-release-line d3875b4e9 -> 051412bec
LENS-1433: Virtual Fact over a fact with single storage - multi update period is writing wrong query Project: http://git-wip-us.apache.org/repos/asf/lens/repo Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/28aa4a1e Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/28aa4a1e Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/28aa4a1e Branch: refs/heads/current-release-line Commit: 28aa4a1e25121849e8ada9e0b843d525e2e1f479 Parents: d3875b4 Author: Rajitha R <rajitha....@gmail.com> Authored: Wed Jun 14 15:06:56 2017 +0530 Committer: rajub <raju.bairishe...@lazada.com> Committed: Mon Jun 19 09:04:45 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/lens/cube/parse/StorageCandidate.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/lens/blob/28aa4a1e/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java ---------------------------------------------------------------------- diff --git a/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java b/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java index c8ff3b8..6e5aa4c 100644 --- a/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java +++ b/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java @@ -265,7 +265,7 @@ public class StorageCandidate implements Candidate, CandidateTable { Set<String> uniqueStorageTables = new HashSet<>(); for (UpdatePeriod updatePeriod : validUpdatePeriods) { uniqueStorageTables.add( - getCubeMetastoreClient().getStorageTableName(fact.getName(), storageName, updatePeriod) + getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, updatePeriod) ); } return uniqueStorageTables; @@ -891,7 +891,7 @@ public class StorageCandidate implements Candidate, CandidateTable { return this.startTime; } return getCubeMetastoreClient().getStorageTableStartDate( - getCubeMetastoreClient().getStorageTableName(fact.getName(), storageName, interval), fact.getName()); + getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, interval), fact.getName()); } private Date getStorageTableEndDate(UpdatePeriod interval) throws LensException { @@ -900,7 +900,7 @@ public class StorageCandidate implements Candidate, CandidateTable { return this.endTime; } return getCubeMetastoreClient().getStorageTableEndDate( - getCubeMetastoreClient().getStorageTableName(fact.getName(), storageName, interval), fact.getName()); + getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, interval), fact.getName()); } @@ -931,7 +931,7 @@ public class StorageCandidate implements Candidate, CandidateTable { StorageCandidate updatePeriodSpecificSc; for (UpdatePeriod period : participatingUpdatePeriods) { updatePeriodSpecificSc = copy(); - updatePeriodSpecificSc.setResolvedName(getCubeMetastoreClient().getStorageTableName(fact.getName(), + updatePeriodSpecificSc.setResolvedName(getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, period)); updatePeriodSpecificSc.truncatePartitions(period); periodSpecificScList.add(updatePeriodSpecificSc);
