We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 151614d commit 134dce5Copy full SHA for 134dce5
backup-s3/src/main/scala/io/aiven/guardian/kafka/backup/s3/BackupClient.scala
@@ -64,7 +64,7 @@ class BackupClient[T <: KafkaClientInterface](maybeS3Settings: Option[S3Settings
64
)
65
single
66
case rest =>
67
- val last = rest.minBy(_.initiated)(Ordering[Instant].reverse)
+ val last = rest.maxBy(_.initiated)(Ordering[Instant])
68
logger.warn(
69
s"Found multiple previously cancelled uploads for key: $key and bucket: ${s3Config.dataBucket}, picking uploadId: ${last.uploadId}"
70
0 commit comments