Skip to content

Commit 1438f78

Browse files
PR Fix
1 parent 66de222 commit 1438f78

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

client/src/main/java/io/split/engine/common/SynchronizerImp.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public void stopPeriodicFetching() {
7474
@Override
7575
public void refreshSplits(long targetChangeNumber) {
7676
int retries = RETRIES_NUMBER;
77-
while(true) {
77+
while(targetChangeNumber > _splitCache.getChangeNumber()) {
7878
retries--;
7979
_splitFetcher.forceRefresh(true);
8080
if (targetChangeNumber <= _splitCache.getChangeNumber()) {

0 commit comments

Comments
 (0)