carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [02/47] incubator-carbondata git commit: [CARBONDATA-91] Concurrent query returning empty result (#849)
Date Mon, 01 Aug 2016 10:05:00 GMT
[CARBONDATA-91] Concurrent query returning empty result (#849)



Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/a5714ace
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/a5714ace
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/a5714ace

Branch: refs/heads/master
Commit: a5714acedb453fcf148222854177f383aa88eaab
Parents: a326bb8
Author: Mohammad Shahid Khan <mohdshahidkhan1987@gmail.com>
Authored: Thu Jul 21 20:00:46 2016 +0530
Committer: Kumar Vishal <kumarvishal.1802@gmail.com>
Committed: Thu Jul 21 20:00:46 2016 +0530

----------------------------------------------------------------------
 .../carbondata/core/carbon/datastore/SegmentTaskIndexStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/a5714ace/core/src/main/java/org/carbondata/core/carbon/datastore/SegmentTaskIndexStore.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/carbondata/core/carbon/datastore/SegmentTaskIndexStore.java
b/core/src/main/java/org/carbondata/core/carbon/datastore/SegmentTaskIndexStore.java
index 28a892e..c94a100 100644
--- a/core/src/main/java/org/carbondata/core/carbon/datastore/SegmentTaskIndexStore.java
+++ b/core/src/main/java/org/carbondata/core/carbon/datastore/SegmentTaskIndexStore.java
@@ -143,7 +143,6 @@ public class SegmentTaskIndexStore {
             if (null == taskIdToSegmentIndexMap) {
               // creating a map of take if to table segment
               taskIdToSegmentIndexMap = new HashMap<String, AbstractIndex>();
-              tableSegmentMapTemp.put(next.getKey(), taskIdToSegmentIndexMap);
               Iterator<Entry<String, List<TableBlockInfo>>> iterator =
                   taskIdToTableBlockInfoMap.entrySet().iterator();
               while (iterator.hasNext()) {
@@ -152,6 +151,7 @@ public class SegmentTaskIndexStore {
                 taskIdToSegmentIndexMap.put(taskId,
                     loadBlocks(taskId, taskToBlockInfoList.getValue(), absoluteTableIdentifier));
               }
+              tableSegmentMapTemp.put(next.getKey(), taskIdToSegmentIndexMap);
               // removing from segment lock map as once segment is loaded
               //if concurrent query is coming for same segment
               // it will wait on the lock so after this segment will be already


Mime
View raw message