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) {