New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[CARBONDATA-4146]Query fails and the error message "unable to get file status" is displayed. query is normal after the "drop metacache on table" command is executed. #4104
Conversation
Can one of the admins verify this patch? |
add to whitelist |
Build Failed with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3780/ |
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5545/ |
…e status" is displayed. query is normal after the "drop metacache on table" command is executed. Why is this PR needed? During compact execution, the status of the new segment is set to success before index files are merged. After index files are merged, the carbonindex files are deleted. As a result, the query task cannot find the cached carbonindex files. What changes were proposed in this PR? Set the status of the new segment to succeeded after index files are merged. Does this PR introduce any user interface change? No Is any new testcase added? No
2e79296
to
57999ab
Compare
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5554/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3788/ |
retest this please |
Build Failed with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3792/ |
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5558/ |
retest this please |
Build Failed with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3794/ |
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5560/ |
retest this please |
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5561/ |
Build Failed with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3795/ |
retest this please |
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5563/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3797/ |
retest this please |
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5565/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3799/ |
@liuhe0702 i think this issue is already being handled in #3988 , so i think no need of this PR, please refer the jira to the jira of #3988 and close as duplicate. @ShreelekhyaG please confirm the same here, where this scenario is being handled or not in your PR. |
Yes @akashrn5/ @liuhe0702 , the same scenario being handled in PR #3988 |
@liuhe0702 please make the jira as duplicate and comment there as its handled in #3988 and close both jira and PR, thanks |
@@ -190,7 +200,7 @@ public boolean execute(List<RawResultIterator> unsortedResultIteratorList, | |||
LOGGER.error(e.getLocalizedMessage(), e); | |||
throw e; | |||
} finally { | |||
if (partitionSpec != null) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Instead of passing boolean value, cant we directly get CarbonCommonConstants.CARBON_MERGE_INDEX_IN_SEGMENT
from properties? and the if check should be - if merge index not enabled, then write segment file. As below,
``` boolean isMergeIndexEnable = Boolean.parseBoolean(CarbonProperties.getInstance().getProperty(
CarbonCommonConstants.CARBON_MERGE_INDEX_IN_SEGMENT,
CarbonCommonConstants.CARBON_MERGE_INDEX_IN_SEGMENT_DEFAULT));
if (partitionSpec != null && !isMergeIndexEnable) { ```
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yes, @liuhe0702 instead of making parameter changes or adding constructors, check property here only and can avoid changes in MergerRDD
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
5c197b4
to
937f644
Compare
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12444/job/ApacheCarbonPRBuilder2.3/5603/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12444/job/ApacheCarbon_PR_Builder_2.4.5/3837/ |
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12545/job/ApacheCarbonPRBuilder2.3/5059/ |
Build Failed with Spark 2.4.5, Please check CI http://121.244.95.60:12602/job/ApacheCarbon_PR_Builder_2.4.5/3307/ |
retest this please |
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12602/job/ApacheCarbonPRBuilder2.3/5069/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12602/job/ApacheCarbon_PR_Builder_2.4.5/3316/ |
retest this please |
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12602/job/ApacheCarbonPRBuilder2.3/5072/ |
CarbonCommonConstants.CARBON_MERGE_INDEX_IN_SEGMENT_DEFAULT)); | ||
// mergeIndex is true, the segment file not need to be wrotten | ||
// and will be wrotten during merging index | ||
if (partitionSpec != null && !isMergeIndex) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
wrotten
to written
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12602/job/ApacheCarbon_PR_Builder_2.4.5/3319/ |
…e status" is displayed. query is normal after the "drop metacache on table" command is executed. not write temp segment file when mergeindex is true
937f644
to
f4c4c0c
Compare
Build Failed with Spark 2.3.4, Please check CI http://121.244.95.60:12602/job/ApacheCarbonPRBuilder2.3/5074/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12602/job/ApacheCarbon_PR_Builder_2.4.5/3321/ |
retest this please |
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12602/job/ApacheCarbonPRBuilder2.3/5076/ |
Build Failed with Spark 2.4.5, Please check CI http://121.244.95.60:12602/job/ApacheCarbon_PR_Builder_2.4.5/3323/ |
retest this please |
Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12602/job/ApacheCarbonPRBuilder2.3/5077/ |
Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12602/job/ApacheCarbon_PR_Builder_2.4.5/3324/ |
LGTM |
1 similar comment
LGTM |
…e status" is displayed. query is normal after the "drop metacache on table" command is executed. Why is this PR needed? During compact execution, the status of the new segment is set to success before index files are merged. After index files are merged, the carbonindex files are deleted. As a result, the query task cannot find the cached carbonindex files. What changes were proposed in this PR? Set the status of the new segment to succeeded after index files are merged. Does this PR introduce any user interface change? No Is any new testcase added? No This closes apache#4104
Why is this PR needed?
During compact execution, the status of the new segment is set to success before index files are merged.
After index files are merged, the carbonindex files are deleted.
As a result, the query task cannot find the cached carbonindex files.
What changes were proposed in this PR?
Set the status of the new segment to succeeded after index files are merged.
Does this PR introduce any user interface change?
No
Is any new testcase added?
No