diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java index e8138e0b..e0aba9fb 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java @@ -371,10 +371,8 @@ public class Scheduler implements Runnable { leaderElectedPeriodicShardSyncManager.start(); streamSyncWatch.start(); isDone = true; - } catch (LeasingException e) { - log.error("Caught exception when initializing LeaseCoordinator", e); - lastException = e; } catch (Exception e) { + log.error("Caught exception when initializing LeaseCoordinator", e); lastException = e; }