From 7f08e8bf4e514275360979c813bc180fb4e7b932 Mon Sep 17 00:00:00 2001 From: Ameya Lokare Date: Wed, 26 Aug 2026 09:37:57 -0700 Subject: [PATCH] Fix overflow when calculating chunk size in ClearOrphanedFoundationDbQueuesCommand --- .../workers/ClearOrphanedFoundationDbQueuesCommand.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearOrphanedFoundationDbQueuesCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearOrphanedFoundationDbQueuesCommand.java index 6d669c71d..6624af409 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearOrphanedFoundationDbQueuesCommand.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearOrphanedFoundationDbQueuesCommand.java @@ -214,7 +214,7 @@ public class ClearOrphanedFoundationDbQueuesCommand extends AbstractCommandWithD CompletableFuture> splitSubspace(final Database database, final int numChunks) { return database.runAsync(transaction -> transaction.getEstimatedRangeSizeBytes(messagesSubspace.range()) .thenCompose(rangeSize -> { - final int chunkSize = Math.toIntExact(Math.ceilDiv(rangeSize, numChunks)); + final long chunkSize = Math.ceilDiv(rangeSize, numChunks); return transaction.getRangeSplitPoints(messagesSubspace.range(), chunkSize); })) .thenApply(result -> splitPointsToRanges(result.getKeys()));