[fix](catalog)Fix internal program error causing client to get stuck (a…

…pache#37551)
ByteYue · Jul 11, 2024 · 9902d59 · 9902d59
1 parent 89845dc
commit 9902d59
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -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();