From 60990cd8d9cb1e78628776f817c039cfc172cbc1 Mon Sep 17 00:00:00 2001 From: Hai Yan <8153134+oeyh@users.noreply.github.com> Date: Thu, 7 Nov 2024 21:16:27 -0600 Subject: [PATCH] Catch all exception during binlog client connect/disconnect (#5176) Signed-off-by: Hai Yan --- .../dataprepper/plugins/source/rds/stream/StreamWorker.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamWorker.java b/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamWorker.java index ed88b196b6..0b92e19d85 100644 --- a/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamWorker.java +++ b/data-prepper-plugins/rds-source/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); } }