-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
[Backport 2.x] [Segment Replication] Add a new Engine implementation for replicas with segment replication enabled. #4003
[Backport 2.x] [Segment Replication] Add a new Engine implementation for replicas with segment replication enabled. #4003
Conversation
…tion for newChangesSnapshotFromTranslogFile() in NRTReplicationEngine Signed-off-by: Rishikesh1159 <[email protected]>
|
||
@Deprecated | ||
@Override | ||
public Translog.Snapshot newChangesSnapshotFromTranslogFile(String source, long fromSeqNo, long toSeqNo, boolean requiredFullRange) |
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.
@mch2 I added this implementation temporarily, let me know if this is good or you just want to return null or entirely remove this method from Engine as it will be deprecated
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.
Removing the method is a breaking change. We can't introduce that in a backport. I would suggest we use the same impl as InternalEngine here.
public Translog.Snapshot newChangesSnapshotFromTranslogFile(String source, long fromSeqNo, long toSeqNo, boolean requiredFullRange)
throws IOException {
return getTranslog().newSnapshot(fromSeqNo, toSeqNo, requiredFullRange);
}
/** | ||
* Return the latest active SegmentInfos from the engine. | ||
* @return {@link SegmentInfos} | ||
*/ | ||
protected abstract SegmentInfos getLatestSegmentInfos(); | ||
|
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.
Isn't this a breaking change for 2.x?
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.
Good call @Rishikesh1159 We'll need to provide default impl here and remove abstract.
Gradle Check (Jenkins) Run Completed with:
|
Codecov Report
@@ Coverage Diff @@
## 2.x #4003 +/- ##
============================================
- Coverage 70.63% 70.53% -0.10%
- Complexity 56487 56514 +27
============================================
Files 4527 4532 +5
Lines 271798 272037 +239
Branches 39975 39987 +12
============================================
- Hits 191985 191887 -98
- Misses 63718 64036 +318
- Partials 16095 16114 +19
Help us with your feedback. Take ten seconds to tell us how you rate us. |
…ava and adressing comments from previous PR Signed-off-by: Rishikesh1159 <[email protected]>
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: Rishikesh1159 [email protected]
Description
This PR backports PR to 2.x branch and resolve conflict in LocalCheckpointTrackerTests, LocalCheckpointTracker classes.
Issues Resolved
#3109
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.