Merge branch 'opensearch-project:main' into main

opensearch-project · Nov 8, 2024 · 4c35661 · 4c35661
2 parents d3a1dd2 + 60990cd
commit 4c35661
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...urce/src/main/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamWorker.java b/...urce/src/main/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamWorker.java
@@ -14,7 +14,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
 import java.util.Optional;
 
 public class StreamWorker {
@@ -57,12 +56,12 @@ public void processStream(final StreamPartition streamPartition) {
         try {
             LOG.info("Connect to database to read change events.");
             binaryLogClient.connect();
-        } catch (IOException e) {
+        } catch (Exception e) {
             throw new RuntimeException(e);
         } finally {
             try {
                 binaryLogClient.disconnect();
-            } catch (IOException e) {
+            } catch (Exception e) {
                 LOG.error("Binary log client failed to disconnect.", e);
             }
         }