From 2cfb411feaf0febb77a66509c553780acf2eae96 Mon Sep 17 00:00:00 2001 From: Meher Mankikar Date: Tue, 20 Jun 2023 12:14:12 -0700 Subject: [PATCH] Bug fix on lease table manager --- .../amazon/kinesis/utils/LeaseTableManager.java | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/LeaseTableManager.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/LeaseTableManager.java index df7a4c3e..18c88538 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/LeaseTableManager.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/LeaseTableManager.java @@ -49,16 +49,17 @@ public class LeaseTableManager { if (i > 100) { throw new RuntimeException("Failed lease table deletion"); } - try { - if (!listAllLeaseTables().contains(tableName)) { - log.info("Succesfully deleted the lease table {}", tableName); - return; - } - } catch (Exception e) { + + List leaseTableNames = listAllLeaseTables(); + log.info("All lease tables name: {}. Looking for: {}", leaseTableNames, tableName); + if (!listAllLeaseTables().contains(tableName)) { + log.info("Succesfully deleted the lease table {}", tableName); + return; + } else { try { Thread.sleep(TimeUnit.SECONDS.toMillis(10)); - } catch (InterruptedException e1) { } - log.info("Lease table {} is not deleted yet, exception: ", tableName, e); + } catch (InterruptedException e1) {} + log.info("Lease table {} is not deleted yet, exception: ", tableName); } } }