From 9902d592acb3bf68243e1c9707be3c2f7d3e001e 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 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()); } 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();