-
Notifications
You must be signed in to change notification settings - Fork 2k
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
[Remote Store] Add Lock Manager in Remote Segment Store to persist data #6787
Conversation
Gradle Check (Jenkins) Run Completed with:
|
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteStoreMDLockManager.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectoryFactory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectoryFactory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteLockIndexOutput.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteLockIndexOutput.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteStoreMDLockManager.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteLockDirectory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectory.java
Outdated
Show resolved
Hide resolved
server/src/test/java/org/opensearch/index/store/RemoteSegmentStoreDirectoryTests.java
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteLockDirectory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteLockIndexOutput.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteLockIndexOutput.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectory.java
Outdated
Show resolved
Hide resolved
a814037
to
b4e361c
Compare
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
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.
Few minor comments, otherwise LGTM. Can you also please create the tracking issues for:
a) race condition discussed here
b) monitor to catch any leaked lock files for which metadata file is not present
server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectory.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/FileLockInfo.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/FileLockInfo.java
Outdated
Show resolved
Hide resolved
a690e95
to
8d102f0
Compare
|
Gradle Check (Jenkins) Run Completed with:
|
server/src/main/java/org/opensearch/index/store/lockmanager/FileLockInfo.java
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/lockmanager/RemoteStoreMetadataLockManager.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteBufferedIndexOutput.java
Show resolved
Hide resolved
server/src/main/java/org/opensearch/index/store/RemoteBufferedIndexOutput.java
Show resolved
Hide resolved
.../src/main/java/org/opensearch/index/store/lockmanager/RemoteStoreCommitLevelLockManager.java
Show resolved
Hide resolved
Signed-off-by: Harish Bhakuni <hbhakuni@amazon.com>
Signed-off-by: Harish Bhakuni <hbhakuni@amazon.com>
Signed-off-by: Harish Bhakuni <hbhakuni@amazon.com>
Signed-off-by: Harish Bhakuni <hbhakuni@amazon.com>
Signed-off-by: Harish Bhakuni <hbhakuni@amazon.com>
8d102f0
to
fa75afd
Compare
Gradle Check (Jenkins) Run Completed with:
|
public void close() throws IOException { | ||
|
||
try (final BytesStreamOutput outStream = out; InputStream stream = out.bytes().streamInput()) { | ||
indexOutputBuffer.close(); |
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.
Should indexOutputBuffer.close();
be in the finally block?
…ta (opensearch-project#6787) Signed-off-by: Harish Bhakuni <hbhakuni@amazon.com> Signed-off-by: Shivansh Arora <hishiv@amazon.com>
… for longer duration.
Description
Changes for Lock Manager in Remote Segment Store to keep data for longer duration and prevent their deletion from Garbage Collection.
Manually Tested Feature End to end on an opensearch cluster.
Check List
Issues Resolved
#6691
#6688
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.