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

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


The following commit(s) were added to refs/heads/master by this push:
     new 85fc8b02e6 [INLONG-9613][TubeMQ] Adjust FATAL type error return 
content, without carrying class name (#10251)
85fc8b02e6 is described below

commit 85fc8b02e69badc5103fadb77559a921c788537a
Author: Goson Zhang <[email protected]>
AuthorDate: Wed May 22 14:14:14 2024 +0800

    [INLONG-9613][TubeMQ] Adjust FATAL type error return content, without 
carrying class name (#10251)
    
    Co-authored-by: gosonzhang <[email protected]>
---
 .../src/main/java/org/apache/inlong/tubemq/corerpc/utils/MixUtils.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/utils/MixUtils.java
 
b/inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/utils/MixUtils.java
index 9663a0e71f..aab3376ea4 100644
--- 
a/inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/utils/MixUtils.java
+++ 
b/inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/utils/MixUtils.java
@@ -75,7 +75,7 @@ public class MixUtils {
             if (strExceptionMsgSet.length > 0) {
                 if (!TStringUtils.isBlank(strExceptionMsgSet[0])) {
                     Class clazz = Class.forName(strExceptionMsgSet[0]);
-                    if (clazz != null) {
+                    if (clazz != null && 
Throwable.class.isAssignableFrom(clazz)) {
                         Constructor<?> ctor = 
clazz.getConstructor(String.class);
                         if (ctor != null) {
                             if (strExceptionMsgSet.length == 1) {

Reply via email to