diff --git a/src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseManager.java b/src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseManager.java index e2970def..7407e84a 100644 --- a/src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseManager.java +++ b/src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseManager.java @@ -115,6 +115,9 @@ public class LeaseManager implements ILeaseManager { request.setProvisionedThroughput(throughput); try { + if (leaseTableExists()) { + return false; + } dynamoDBClient.createTable(request); } catch (ResourceInUseException e) { tableDidNotExist = false;