diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java index 0a6a2ad1..7af76661 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java @@ -623,7 +623,8 @@ public class DynamoDBLeaseRefresher implements LeaseRefresher { 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(); if (describeTableResponse == null) { log.info("DescribeTable returned null so using default totalSegments : {}", parallelScanTotalSegments);