Skip to content

Commit a2e0ba5

Browse files
committed
fix: replication initialization is not using the latest backup
1 parent a359647 commit a2e0ba5

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

stackgres-k8s/src/operator/src/main/java/io/stackgres/operator/conciliation/cluster/ClusterRequiredResourcesGenerator.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -378,12 +378,13 @@ private Optional<Tuple2<StackGresBackup, Map<String, Secret>>> getReplicationIni
378378
.map(Instant::parse)
379379
.filter(end -> backupNewerThan.map(end::isAfter).orElse(true))
380380
.isPresent())
381-
.sorted(Comparator.comparing(backup -> Optional.ofNullable(backup.getStatus())
381+
.sorted(Comparator.comparing((StackGresBackup backup) -> Optional.ofNullable(backup.getStatus())
382382
.map(StackGresBackupStatus::getProcess)
383383
.map(StackGresBackupProcess::getTiming)
384384
.map(StackGresBackupTiming::getEnd)
385385
.map(Instant::parse)
386-
.get()))
386+
.get())
387+
.reversed())
387388
.map(backup -> Tuple.tuple(
388389
backup,
389390
Optional.of(backup)

0 commit comments

Comments
 (0)