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

Merge 620d36559d into 8d339bdb88

Browse source
This commit is contained in:
Brian M. Carr 2017-04-12 20:22:36 +00:00 committed by GitHub
commit e28d756ed7
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseManager.java
View file

@ -124,6 +124,9 @@ public class LeaseManager<T extends Lease> implements ILeaseManager<T> {
request.setProvisionedThroughput(throughput); request.setProvisionedThroughput(throughput);
try { try {
if (leaseTableExists()) {
return false;
}
dynamoDBClient.createTable(request); dynamoDBClient.createTable(request);
} catch (ResourceInUseException e) { } catch (ResourceInUseException e) {
LOG.info("Table " + table + " already exists."); LOG.info("Table " + table + " already exists.");