From 52199a24ee081eaa1110d4b85187b4774edec597 Mon Sep 17 00:00:00 2001
From: bencvdb <bencvdb93#gmail.com>
Date: Wed, 7 Jul 2021 08:29:42 -0700
Subject: [PATCH] refactor(worker): broaden exception handling

---
 .../services/kinesis/clientlibrary/lib/worker/Worker.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java b/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
index 70b232b7..c72148e0 100644
--- a/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
+++ b/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
@@ -619,12 +619,11 @@ public class Worker implements Runnable {
                     lastException = result.getException();
                     handleMissingIncompleteLeasesException(lastException);
                 }
-            } catch (MissingIncompleteLeasesException e) {
-                throw e;
             } catch (LeasingException e) {
                 LOG.error("Caught exception when initializing LeaseCoordinator", e);
                 lastException = e;
             } catch (Exception e) {
+                handleMissingIncompleteLeasesException(e);
                 lastException = e;
             }