From b6a9bc5b9315f8a804b45a0902722d1b68780531 Mon Sep 17 00:00:00 2001
From: zhangdong <493738387@qq.com>
Date: Tue, 9 Jul 2024 12:04:49 +0800
Subject: [PATCH 1/2] 1

---
 .../src/main/java/org/apache/doris/mysql/ReadListener.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/ReadListener.java b/fe/fe-core/src/main/java/org/apache/doris/mysql/ReadListener.java
index 2de6f80f05d341..c43954a98b1240 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mysql/ReadListener.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mysql/ReadListener.java
@@ -56,7 +56,7 @@ public void handleEvent(ConduitStreamSourceChannel channel) {
                     ctx.stopAcceptQuery();
                     ctx.cleanup();
                 }
-            } catch (Exception e) {
+            } catch (Throwable e) {
                 LOG.warn("Exception happened in one session(" + ctx + ").", e);
                 ctx.setKilled();
                 ctx.cleanup();

From 491200172045abd3703b81398a3f39a21e76cd48 Mon Sep 17 00:00:00 2001
From: zhangdong <493738387@qq.com>
Date: Tue, 9 Jul 2024 12:39:14 +0800
Subject: [PATCH 2/2] 1

---
 .../main/java/org/apache/doris/datasource/CatalogFactory.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogFactory.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogFactory.java
index cd75eab4650be7..263d3fbca2f546 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogFactory.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogFactory.java
@@ -161,7 +161,7 @@ private static CatalogIf createCatalog(long catalogId, String name, String resou
             // If failed, it will throw exception and the catalog will not be created.
             try {
                 catalog.initAccessController(true);
-            } catch (Exception e) {
+            } catch (Throwable e) {
                 LOG.warn("Failed to init access controller", e);
                 throw new DdlException("Failed to init access controller: " + e.getMessage());
             }