-
Couldn't load subscription status.
- Fork 176
Implement vacuum index operation #2557
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
Implement vacuum index operation #2557
Conversation
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #2557 +/- ##
============================================
- Coverage 95.53% 95.50% -0.03%
- Complexity 5101 5113 +12
============================================
Files 488 489 +1
Lines 14261 14310 +49
Branches 958 961 +3
============================================
+ Hits 13624 13667 +43
- Misses 614 618 +4
- Partials 23 25 +2
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
|
Will address conflicts once #2554 merged |
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
Signed-off-by: Chen Dai <daichen@amazon.com>
| stateStore, dispatchQueryRequest.getDatasource(), emrServerlessClient); | ||
| try { | ||
| tryDropOp.apply(indexMetadata); | ||
| } catch (IllegalStateException e) { |
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.
Do we want to ignore only IllegalStateException or any kind of error?
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.
I think only the IllegalStateException thrown from validation? If any exception occurred during operation and commit, there is no need to continue.
* Add vacuum operation and IT Signed-off-by: Chen Dai <daichen@amazon.com> * Add index state doc delete and more IT Signed-off-by: Chen Dai <daichen@amazon.com> * Refactor IT Signed-off-by: Chen Dai <daichen@amazon.com> * Fix bytebuddy version conflict Signed-off-by: Chen Dai <daichen@amazon.com> * Fix broken IT Signed-off-by: Chen Dai <daichen@amazon.com> * Fix broken IT Signed-off-by: Chen Dai <daichen@amazon.com> * Fix jacoco failure with new IT Signed-off-by: Chen Dai <daichen@amazon.com> * Fix code format Signed-off-by: Chen Dai <daichen@amazon.com> * Fix jacoco test coverage Signed-off-by: Chen Dai <daichen@amazon.com> --------- Signed-off-by: Chen Dai <daichen@amazon.com> (cherry picked from commit 8374cb6) Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
* Add vacuum operation and IT * Add index state doc delete and more IT * Refactor IT * Fix bytebuddy version conflict * Fix broken IT * Fix broken IT * Fix jacoco failure with new IT * Fix code format * Fix jacoco test coverage --------- (cherry picked from commit 8374cb6) Signed-off-by: Chen Dai <daichen@amazon.com> Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com> Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
Description
Implemented the
VACUUMindex statement in the plugin. The semantics slightly differ from what's defined in Flint Spark: similar to the currentDROPindex logic in the plugin, the vacuum operation can transition fromREFRESHING,ACTIVE, orDELETEDstates directly, instead of only acceptingDELETED.Issues Resolved
opensearch-project/opensearch-spark#104
Check List
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.