bugfix: kryo support circular reference (apache#4978)

conghuhu · Oct 9, 2022 · f300ca6 · f300ca6
1 parent 1cbc19c
commit f300ca6
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git a/changes/en-us/develop.md b/changes/en-us/develop.md
@@ -21,6 +21,7 @@ Add changes here for all PR submitted to the develop branch.
 - [[#4919](https://github.com/seata/seata/pull/4919)] fix XID port  and  address null:0 before coordinator.init
 - [[#4928](https://github.com/seata/seata/pull/4928)] fix rpcContext.getClientRMHolderMap NPE 
 - [[#4953](https://github.com/seata/seata/pull/4953)] fix InsertOnDuplicateUpdate bypass modify pk
+- [[#4978](https://github.com/seata/seata/pull/4978)] fix kryo support circular reference
 
 ### optimize:
 - [[#4774](https://github.com/seata/seata/pull/4774)] optimize mysql8 dependencies for seataio/seata-server image

diff --git a/changes/zh-cn/develop.md b/changes/zh-cn/develop.md
@@ -21,6 +21,7 @@
 - [[#4919](https://github.com/seata/seata/pull/4919)] 修复XID的port和address出现null:0的情况
 - [[#4928](https://github.com/seata/seata/pull/4928)] 修复 rpcContext.getClientRMHolderMap NPE 问题
 - [[#4953](https://github.com/seata/seata/pull/4953)] 修复InsertOnDuplicateUpdate可绕过修改主键的问题
+- [[#4978](https://github.com/seata/seata/pull/4978)] 修复 kryo 支持循环依赖
 
 ### optimize：
 - [[#4774](https://github.com/seata/seata/pull/4774)] 优化 seataio/seata-server 镜像中的 mysql8 依赖

diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/undo/parser/KryoSerializerFactory.java b/rm-datasource/src/main/java/io/seata/rm/datasource/undo/parser/KryoSerializerFactory.java
@@ -47,6 +47,7 @@ public class KryoSerializerFactory {
         @Override
         public Kryo create() {
             Kryo kryo = new Kryo();
+            kryo.setReferences(true);
             kryo.setRegistrationRequired(false);
 
             for (Map.Entry<Class, Serializer> entry : TYPE_MAP.entrySet()) {

diff --git a/...r/seata-serializer-kryo/src/main/java/io/seata/serializer/kryo/KryoSerializerFactory.java b/...r/seata-serializer-kryo/src/main/java/io/seata/serializer/kryo/KryoSerializerFactory.java
@@ -48,6 +48,7 @@ public class KryoSerializerFactory {
         @Override
         protected Kryo create() {
             Kryo kryo = new Kryo();
+            kryo.setReferences(true);
             kryo.setRegistrationRequired(false);
 
             // register serializer