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 226756eb..f8fd1f9d 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 @@ -124,6 +124,9 @@ public class LeaseManager implements ILeaseManager { request.setProvisionedThroughput(throughput); try { + if (leaseTableExists()) { + return false; + } dynamoDBClient.createTable(request); } catch (ResourceInUseException e) { LOG.info("Table " + table + " already exists.");