We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ce6bf60 commit 19c6c7aCopy full SHA for 19c6c7a
1 file changed
src/main/java/com/uid2/operator/store/CloudSyncOptOutStore.java
@@ -542,7 +542,7 @@ else if (OptOutUtils.isPartitionFile(f))
542
543
Instant tsOld = OptOutUtils.lastPartitionTimestamp(indexedNonSynthetic);
544
Instant tsNew = OptOutUtils.lastPartitionTimestamp(newNonSynthetic);
545
- if (tsOld != Instant.EPOCH && tsNew != Instant.EPOCH && tsOld.isBefore(tsNew)) {
+ if (tsOld != Instant.EPOCH && tsNew != Instant.EPOCH && !tsOld.isBefore(tsNew)) {
546
final String errorMsg = "Last partition timestamp of indexed files " + tsOld.getEpochSecond()
547
+ " is after last partition of non-indexed files " + tsNew.getEpochSecond();
548
LOGGER.error(errorMsg);
0 commit comments