File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
main/java/org/opensearch/index/remote
test/java/org/opensearch/index/remote Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ public class RemoteSegmentTransferTracker extends RemoteTransferTracker {
6565 private volatile long remoteRefreshSeqNo ;
6666
6767 /**
68- * The refresh time of most recent remote refresh.
68+ * The refresh time of the most recent remote refresh.
6969 */
7070 private volatile long remoteRefreshTimeMs ;
7171
@@ -76,7 +76,7 @@ public class RemoteSegmentTransferTracker extends RemoteTransferTracker {
7676 private volatile long remoteRefreshStartTimeMs = -1 ;
7777
7878 /**
79- * The refresh time(clock) of most recent remote refresh.
79+ * The refresh time(clock) of the most recent remote refresh.
8080 */
8181 private volatile long remoteRefreshClockTimeMs ;
8282
Original file line number Diff line number Diff line change @@ -154,13 +154,13 @@ public void testComputeTimeLagOnUpdate() throws InterruptedException {
154154 transferTracker .updateLatestLocalFileNameLengthMap (List .of ("test" ), k -> 1L );
155155 // Sleep for 100ms and then the lag should be within 100ms +/- 20ms
156156 Thread .sleep (100 );
157- assertTrue (Math . abs ( transferTracker .getTimeMsLag () - 100 ) <= 20 );
157+ assertTrue (transferTracker .getTimeMsLag () >= 100 );
158158
159159 transferTracker .updateRemoteRefreshTimeMs (transferTracker .getLocalRefreshTimeMs ());
160160 transferTracker .updateLocalRefreshTimeMs (currentTimeMsUsingSystemNanos ());
161161 long random = randomIntBetween (50 , 200 );
162162 Thread .sleep (random );
163- assertTrue (Math . abs ( transferTracker .getTimeMsLag () - random ) <= 20 );
163+ assertTrue (transferTracker .getTimeMsLag () >= random );
164164 }
165165
166166 public void testAddUploadBytesStarted () {
You can’t perform that action at this time.
0 commit comments