You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ku...@apache.org on 2018/09/21 11:16:45 UTC
carbondata git commit: [HOTFIX] Correct metrics and avoid twice read
when prefetch is disabled
Repository: carbondata
Updated Branches:
refs/heads/master 817230da1 -> b04269b2b
[HOTFIX] Correct metrics and avoid twice read when prefetch is disabled
When prefetch is disabled in full scan queries read twice the data. This PR removes extra read.
This closes #2737
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/b04269b2
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/b04269b2
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/b04269b2
Branch: refs/heads/master
Commit: b04269b2b8d05ce21e2fb4f8ebeab668e902aba7
Parents: 817230d
Author: ravipesala <ra...@gmail.com>
Authored: Thu Sep 20 14:44:09 2018 +0530
Committer: kumarvishal09 <ku...@gmail.com>
Committed: Fri Sep 21 16:46:15 2018 +0530
----------------------------------------------------------------------
.../carbondata/core/scan/scanner/impl/BlockletFullScanner.java | 3 ---
1 file changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/carbondata/blob/b04269b2/core/src/main/java/org/apache/carbondata/core/scan/scanner/impl/BlockletFullScanner.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/carbondata/core/scan/scanner/impl/BlockletFullScanner.java b/core/src/main/java/org/apache/carbondata/core/scan/scanner/impl/BlockletFullScanner.java
index f61a8b1..4ec8cb6 100644
--- a/core/src/main/java/org/apache/carbondata/core/scan/scanner/impl/BlockletFullScanner.java
+++ b/core/src/main/java/org/apache/carbondata/core/scan/scanner/impl/BlockletFullScanner.java
@@ -84,9 +84,6 @@ public class BlockletFullScanner implements BlockletScanner {
String blockletId = blockExecutionInfo.getBlockIdString() + CarbonCommonConstants.FILE_SEPARATOR
+ rawBlockletColumnChunks.getDataBlock().blockletIndex();
scannedResult.setBlockletId(blockletId);
- if (!blockExecutionInfo.isPrefetchBlocklet()) {
- readBlocklet(rawBlockletColumnChunks);
- }
DimensionRawColumnChunk[] dimensionRawColumnChunks =
rawBlockletColumnChunks.getDimensionRawColumnChunks();
DimensionColumnPage[][] dimensionColumnDataChunks =