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

Fall back to previously calculated totalScan

Browse source
This commit is contained in:
eha sah 2025-03-11 13:13:44 -07:00
parent 4a59562cb7
commit 5ca6800085
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -622,11 +622,9 @@ public class DynamoDBLeaseRefresher implements LeaseRefresher {
if (isTotalSegmentsCacheValid()) { if (isTotalSegmentsCacheValid()) {
return cachedTotalSegments; return cachedTotalSegments;
} }
int parallelScanTotalSegments = DEFAULT_LEASE_TABLE_SCAN_PARALLELISM_FACTOR;
if (isTotalSegmentsCacheValid()) { int parallelScanTotalSegments = cachedTotalSegments == null ? DEFAULT_LEASE_TABLE_SCAN_PARALLELISM_FACTOR : cachedTotalSegments;
return cachedTotalSegments; final DescribeTableResponse describeTableResponse = describeLeaseTable();
}
DescribeTableResponse describeTableResponse = describeLeaseTable();
if (describeTableResponse == null) { if (describeTableResponse == null) {
log.info("DescribeTable returned null so using default totalSegments : {}", parallelScanTotalSegments); log.info("DescribeTable returned null so using default totalSegments : {}", parallelScanTotalSegments);
} else { } else {