You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2016/08/01 10:05:00 UTC
[02/47] incubator-carbondata git commit: [CARBONDATA-91] Concurrent
query returning empty result (#849)
[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 <mo...@gmail.com>
Authored: Thu Jul 21 20:00:46 2016 +0530
Committer: Kumar Vishal <ku...@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