Skip to content

Commit 73f1679

Browse files
chillaqsanzmauro
andauthored
Update client/src/main/java/io/split/engine/common/SynchronizerImp.java
Co-authored-by: Mauro Sanz <51236193+sanzmauro@users.noreply.github.com>
1 parent 9f835ab commit 73f1679

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -118,8 +118,7 @@ private SyncResult attemptSplitsSync(long targetChangeNumber, long ruleBasedSegm
118118
if (fetchResult != null && !fetchResult.retry() && !fetchResult.isSuccess()) {
119119
return new SyncResult(false, remainingAttempts, fetchResult);
120120
}
121-
if ((targetChangeNumber != 0 && targetChangeNumber <= _splitCacheProducer.getChangeNumber()) ||
122-
(ruleBasedSegmentChangeNumber != 0 && ruleBasedSegmentChangeNumber <= _ruleBasedSegmentCacheProducer.getChangeNumber())) {
121+
if (targetChangeNumber <= _splitCacheProducer.getChangeNumber() && ruleBasedSegmentChangeNumber <= _ruleBasedSegmentCacheProducer.getChangeNumber()) {
123122
return new SyncResult(true, remainingAttempts, fetchResult);
124123
} else if (remainingAttempts <= 0) {
125124
return new SyncResult(false, remainingAttempts, fetchResult);

0 commit comments

Comments
 (0)