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

fixed formating

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

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

@ -623,7 +623,8 @@ public class DynamoDBLeaseRefresher implements LeaseRefresher {
return cachedTotalSegments; return cachedTotalSegments;
} }
int parallelScanTotalSegments = cachedTotalSegments == null ? DEFAULT_LEASE_TABLE_SCAN_PARALLELISM_FACTOR : cachedTotalSegments; int parallelScanTotalSegments =
cachedTotalSegments == null ? DEFAULT_LEASE_TABLE_SCAN_PARALLELISM_FACTOR : cachedTotalSegments;
final DescribeTableResponse describeTableResponse = describeLeaseTable(); final 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);