luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Removed un-necessary exception handling

Browse source
This commit is contained in:
eha sah 2025-03-04 11:52:36 -08:00
parent 4d7392f04e
commit 2e5971b000
1 changed files with 3 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java
View file

@ -625,20 +625,9 @@ public class DynamoDBLeaseRefresher implements LeaseRefresher {
*/
private int getParallelScanTotalSegments(double tableSizeBytes) {
int totalSegments = DEFAULT_LEASE_TABLE_SCAN_PARALLELISM_FACTOR;
try {
double tableSizeGB = tableSizeBytes / NUMBER_OF_BYTES_PER_GB;
totalSegments = (int) Math.ceil(tableSizeGB / GB_PER_SEGMENT);
} catch (Exception e) {
log.info(
"Error while getting totalSegments so using default totalSegments : {}. Exception : {}",
DEFAULT_LEASE_TABLE_SCAN_PARALLELISM_FACTOR,
e.getMessage());
return totalSegments;
}
totalSegments = Math.min(Math.max(totalSegments, MIN_SCAN_SEGMENTS), MAX_SCAN_SEGMENTS);
double tableSizeGB = tableSizeBytes / NUMBER_OF_BYTES_PER_GB;
int totalSegments =
Math.min(Math.max((int) Math.ceil(tableSizeGB / GB_PER_SEGMENT), MIN_SCAN_SEGMENTS), MAX_SCAN_SEGMENTS);
log.info("TotalSegments for Lease table parallel scan : {}", totalSegments);
return totalSegments;
}