LENS-1414: StorageCandidates not getting pruned for non continuous update period
Project: http://git-wip-us.apache.org/repos/asf/lens/repo Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/44a266a0 Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/44a266a0 Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/44a266a0 Branch: refs/heads/current-release-line Commit: 44a266a0fccf2162a66bf40e262e83c013ff776e Parents: cb48aa3 Author: Sushil Mohanty <sushil.k.moha...@gmail.com> Authored: Fri Apr 28 14:55:06 2017 +0530 Committer: Rajat Khandelwal <rajatgupt...@gmail.com> Committed: Fri Apr 28 14:55:06 2017 +0530 ---------------------------------------------------------------------- .../main/java/org/apache/lens/cube/parse/StorageTableResolver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/lens/blob/44a266a0/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageTableResolver.java ---------------------------------------------------------------------- diff --git a/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageTableResolver.java b/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageTableResolver.java index 10c3bbe..957b9ff 100644 --- a/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageTableResolver.java +++ b/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageTableResolver.java @@ -327,7 +327,7 @@ class StorageTableResolver implements ContextRewriter { //This is the prune cause pruningCauseForThisTimeRange = new CandidateTablePruneCause(CandidateTablePruneCode.TIME_RANGE_NOT_ANSWERABLE); - } else if (cubeql.shouldReplaceTimeDimWithPart()) { + } else if (!sc.getValidUpdatePeriods().contains(UpdatePeriod.CONTINUOUS)) { if (!client.partColExists(sc.getFact().getName(), sc.getStorageName(), range.getPartitionColumn())) { pruningCauseForThisTimeRange = partitionColumnsMissing(range.getPartitionColumn()); TimeRange fallBackRange = StorageUtil.getFallbackRange(range, sc.getFact().getName(), cubeql);
