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 =