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()));