From ced5e0d33bdb213cb94f5bc23fcd7f21bca5be9c Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Thu, 11 Jul 2024 20:21:26 +0800 Subject: [PATCH] [fix](catalog)Fix internal program error causing client to get stuck (#37551) --- .../main/java/org/apache/doris/datasource/CatalogFactory.java | 2 +- .../src/main/java/org/apache/doris/mysql/ReadListener.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 23558ce57681ef..fdd3b8fbe02fe5 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 @@ -153,7 +153,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()); } 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();