This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 9902d592acb [fix](catalog)Fix internal program error causing client to 
get stuck (#37551)
9902d592acb is described below

commit 9902d592acb3bf68243e1c9707be3c2f7d3e001e
Author: zhangdong <493738...@qq.com>
AuthorDate: Thu Jul 11 20:21:26 2024 +0800

    [fix](catalog)Fix internal program error causing client to get stuck 
(#37551)
---
 .../src/main/java/org/apache/doris/datasource/CatalogFactory.java       | 2 +-
 fe/fe-core/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 cd75eab4650..263d3fbca2f 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 @@ public class CatalogFactory {
             // 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 2de6f80f05d..c43954a98b1 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 class ReadListener implements 
ChannelListener<ConduitStreamSourceChannel>
                     ctx.stopAcceptQuery();
                     ctx.cleanup();
                 }
-            } catch (Exception e) {
+            } catch (Throwable e) {
                 LOG.warn("Exception happened in one session(" + ctx + ").", e);
                 ctx.setKilled();
                 ctx.cleanup();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to