This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.3 by this push:
new 3bd6c85784 Fix input stream unable to being deserialized (#14837)
3bd6c85784 is described below
commit 3bd6c8578444879190a2aca7f5534d9192d2532a
Author: Albumen Kevin <[email protected]>
AuthorDate: Tue Oct 29 14:49:29 2024 +0800
Fix input stream unable to being deserialized (#14837)
---
.../common/serialize/hessian2/Hessian2SerializerFactory.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2SerializerFactory.java
b/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2SerializerFactory.java
index 71eb60c2f4..f907e16444 100644
---
a/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2SerializerFactory.java
+++
b/dubbo-serialization/dubbo-serialization-hessian2/src/main/java/org/apache/dubbo/common/serialize/hessian2/Hessian2SerializerFactory.java
@@ -67,6 +67,10 @@ public class Hessian2SerializerFactory extends
SerializerFactory {
@Override
protected Deserializer getDefaultDeserializer(Class cl) {
+ if (InputStream.class.equals(cl)) {
+ return InputStreamDeserializer.DESER;
+ }
+
try {
// pre-check if class is allow
defaultSerializeClassChecker.loadClass(getClassLoader(),
cl.getName());
@@ -76,9 +80,7 @@ public class Hessian2SerializerFactory extends
SerializerFactory {
checkSerializable(cl);
- if (InputStream.class.equals(cl)) {
- return InputStreamDeserializer.DESER;
- } else if (RecordUtil.isRecord(cl)) {
+ if (RecordUtil.isRecord(cl)) {
return new RecordDeserializer(cl, getFieldDeserializerFactory());
} else {
if (isEnableUnsafeSerializer()) {
