diff --git a/java/fury-core/src/main/java/org/apache/fury/builder/BaseObjectCodecBuilder.java b/java/fury-core/src/main/java/org/apache/fury/builder/BaseObjectCodecBuilder.java
index dc4765250d..7507810582 100644
--- a/java/fury-core/src/main/java/org/apache/fury/builder/BaseObjectCodecBuilder.java
+++ b/java/fury-core/src/main/java/org/apache/fury/builder/BaseObjectCodecBuilder.java
@@ -1214,7 +1214,7 @@ protected Expression deserializeForCollection(
     }
     Invoke supportHook = inlineInvoke(serializer, "supportCodegenHook", PRIMITIVE_BOOLEAN_TYPE);
     Expression collection = new Invoke(serializer, "newCollection", COLLECTION_TYPE, buffer);
-    Expression size = new Invoke(serializer, "getNumElements", "size", PRIMITIVE_INT_TYPE);
+    Expression size = new Invoke(serializer, "getAndClearNumElements", "size", PRIMITIVE_INT_TYPE);
     // if add branch by `ArrayList`, generated code will be > 325 bytes.
     // and List#add is more likely be inlined if there is only one subclass.
     Expression hookRead = readCollectionCodegen(buffer, collection, size, elementType);
@@ -1442,7 +1442,7 @@ protected Expression deserializeForMap(
     }
     Invoke supportHook = inlineInvoke(serializer, "supportCodegenHook", PRIMITIVE_BOOLEAN_TYPE);
     Expression newMap = new Invoke(serializer, "newMap", MAP_TYPE, buffer);
-    Expression size = new Invoke(serializer, "getNumElements", "size", PRIMITIVE_INT_TYPE);
+    Expression size = new Invoke(serializer, "getAndClearNumElements", "size", PRIMITIVE_INT_TYPE);
     Expression start = new Literal(0, PRIMITIVE_INT_TYPE);
     Expression step = new Literal(1, PRIMITIVE_INT_TYPE);
     ExprHolder exprHolder = ExprHolder.of("map", newMap, "buffer", buffer);
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractCollectionSerializer.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractCollectionSerializer.java
index 3ddc9587ec..93baa9b99b 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractCollectionSerializer.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractCollectionSerializer.java
@@ -40,7 +40,7 @@
 @SuppressWarnings({"unchecked", "rawtypes"})
 public abstract class AbstractCollectionSerializer<T> extends Serializer<T> {
   private MethodHandle constructor;
-  protected int numElements;
+  private int numElements;
   private final boolean supportCodegenHook;
   // TODO remove elemSerializer, support generics in CompatibleSerializer.
   private Serializer<?> elemSerializer;
@@ -507,9 +507,19 @@ public Collection newCollection(MemoryBuffer buffer) {
     }
   }
 
-  /** Get numElements of deserializing collection. Should be called after {@link #newCollection}. */
-  public int getNumElements() {
-    return numElements;
+  /**
+   * Get and reset numElements of deserializing collection. Should be called after {@link
+   * #newCollection}. Nested read may overwrite this element, reset is necessary to avoid use wrong
+   * value by mistake.
+   */
+  public int getAndClearNumElements() {
+    int size = numElements;
+    numElements = -1; // nested read may overwrite this element.
+    return size;
+  }
+
+  protected void setNumElements(int numElements) {
+    this.numElements = numElements;
   }
 
   public abstract T onCollectionRead(Collection collection);
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractMapSerializer.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractMapSerializer.java
index 285163c648..7f5de4032b 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractMapSerializer.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/AbstractMapSerializer.java
@@ -61,7 +61,7 @@ public abstract class AbstractMapSerializer<T> extends Serializer<T> {
   // field. So we will write those extra kv classes to keep protocol consistency between
   // interpreter and jit mode although it seems unnecessary.
   // With kv header in future, we can write this kv classes only once, the cost won't be too much.
-  protected int numElements;
+  private int numElements;
 
   public AbstractMapSerializer(Fury fury, Class<T> cls) {
     this(fury, cls, !ReflectionUtils.isDynamicGeneratedCLass(cls));
@@ -718,9 +718,18 @@ public Map newMap(MemoryBuffer buffer) {
     }
   }
 
-  /** Get numElements of deserializing collection. Should be called after {@link #newMap}. */
-  public int getNumElements() {
-    return numElements;
+  /**
+   * Get and reset numElements of deserializing collection. Should be called after {@link #newMap}.
+   * Nested read may overwrite this element, reset is necessary to avoid use wrong value by mistake.
+   */
+  public int getAndClearNumElements() {
+    int size = numElements;
+    numElements = -1; // nested read may overwrite this element.
+    return size;
+  }
+
+  public void setNumElements(int numElements) {
+    this.numElements = numElements;
   }
 
   public abstract T onMapRead(Map map);
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ChildContainerSerializers.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ChildContainerSerializers.java
index 3580e6cfac..eb0f1d9e8d 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ChildContainerSerializers.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ChildContainerSerializers.java
@@ -159,6 +159,8 @@ public ChildArrayListSerializer(Fury fury, Class<T> cls) {
     @Override
     public T newCollection(MemoryBuffer buffer) {
       T collection = (T) super.newCollection(buffer);
+      int numElements = getAndClearNumElements();
+      setNumElements(numElements);
       collection.ensureCapacity(numElements);
       return collection;
     }
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializer.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializer.java
index 7ef86bcb51..698fdb291e 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializer.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializer.java
@@ -48,6 +48,7 @@ public T onCollectionRead(Collection collection) {
   @Override
   public T read(MemoryBuffer buffer) {
     Collection collection = newCollection(buffer);
+    int numElements = getAndClearNumElements();
     if (numElements != 0) {
       readElements(fury, buffer, collection, numElements);
     }
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializers.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializers.java
index 53ae945e77..b21456a55f 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializers.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/CollectionSerializers.java
@@ -71,7 +71,8 @@ public short getXtypeId() {
 
     @Override
     public ArrayList newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       ArrayList arrayList = new ArrayList(numElements);
       fury.getRefResolver().reference(arrayList);
       return arrayList;
@@ -147,7 +148,8 @@ public short getXtypeId() {
 
     @Override
     public HashSet newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       HashSet hashSet = new HashSet(numElements);
       fury.getRefResolver().reference(hashSet);
       return hashSet;
@@ -166,7 +168,8 @@ public short getXtypeId() {
 
     @Override
     public LinkedHashSet newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       LinkedHashSet hashSet = new LinkedHashSet(numElements);
       fury.getRefResolver().reference(hashSet);
       return hashSet;
@@ -197,7 +200,8 @@ public Collection onCollectionWrite(MemoryBuffer buffer, T value) {
     @SuppressWarnings("unchecked")
     @Override
     public T newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       T collection;
       Comparator comparator = (Comparator) fury.readRef(buffer);
       if (type == TreeSet.class) {
@@ -376,7 +380,8 @@ public ConcurrentSkipListSetSerializer(Fury fury, Class<ConcurrentSkipListSet> c
 
     @Override
     public ConcurrentSkipListSet newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       Comparator comparator = (Comparator) fury.readRef(buffer);
       ConcurrentSkipListSet skipListSet = new ConcurrentSkipListSet(comparator);
       fury.getRefResolver().reference(skipListSet);
@@ -392,7 +397,8 @@ public VectorSerializer(Fury fury, Class<Vector> cls) {
 
     @Override
     public Vector newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       Vector<Object> vector = new Vector<>(numElements);
       fury.getRefResolver().reference(vector);
       return vector;
@@ -407,7 +413,8 @@ public ArrayDequeSerializer(Fury fury, Class<ArrayDeque> cls) {
 
     @Override
     public ArrayDeque newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       ArrayDeque deque = new ArrayDeque(numElements);
       fury.getRefResolver().reference(deque);
       return deque;
@@ -486,7 +493,8 @@ public Collection onCollectionWrite(MemoryBuffer buffer, PriorityQueue value) {
 
     @Override
     public PriorityQueue newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       Comparator comparator = (Comparator) fury.readRef(buffer);
       PriorityQueue queue = new PriorityQueue(comparator);
       fury.getRefResolver().reference(queue);
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/FuryArrayAsListSerializer.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/FuryArrayAsListSerializer.java
index 4c61999325..b20d4ab87e 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/FuryArrayAsListSerializer.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/FuryArrayAsListSerializer.java
@@ -39,7 +39,8 @@ public short getXtypeId() {
   }
 
   public Collection newCollection(MemoryBuffer buffer) {
-    numElements = buffer.readPositiveVarInt();
+    int numElements = buffer.readPositiveVarInt();
+    setNumElements(numElements);
     return new ArrayAsList(numElements);
   }
 }
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/GuavaCollectionSerializers.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/GuavaCollectionSerializers.java
index dc7c93be8d..f6d0e88968 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/GuavaCollectionSerializers.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/GuavaCollectionSerializers.java
@@ -73,7 +73,8 @@ public ImmutableListSerializer(Fury fury, Class<T> cls) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       return new CollectionContainer<>(numElements);
     }
 
@@ -124,7 +125,8 @@ public RegularImmutableListSerializer(Fury fury, Class<T> cls) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       return new CollectionContainer(numElements);
     }
 
@@ -156,7 +158,8 @@ public ImmutableSetSerializer(Fury fury, Class<T> cls) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       return new CollectionContainer<>(numElements);
     }
 
@@ -195,7 +198,8 @@ public Collection onCollectionWrite(MemoryBuffer buffer, T value) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       Comparator comparator = (Comparator) fury.readRef(buffer);
       return new SortedCollectionContainer(comparator, numElements);
     }
@@ -221,7 +225,9 @@ public GuavaMapSerializer(Fury fury, Class<T> cls) {
 
     @Override
     public Map newMap(MemoryBuffer buffer) {
-      return new MapContainer(numElements = buffer.readPositiveVarInt());
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
+      return new MapContainer(numElements);
     }
 
     @Override
@@ -333,7 +339,8 @@ public Map onMapWrite(MemoryBuffer buffer, T value) {
 
     @Override
     public Map newMap(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       Comparator comparator = (Comparator) fury.readRef(buffer);
       return new SortedMapContainer<>(comparator, numElements);
     }
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ImmutableCollectionSerializers.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ImmutableCollectionSerializers.java
index 9f78f3978b..75c9ea808c 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ImmutableCollectionSerializers.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/ImmutableCollectionSerializers.java
@@ -109,7 +109,8 @@ public ImmutableListSerializer(Fury fury, Class cls) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       if (Platform.JAVA_VERSION > 8) {
         return new CollectionContainer<>(numElements);
       } else {
@@ -141,7 +142,8 @@ public ImmutableSetSerializer(Fury fury, Class cls) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       if (Platform.JAVA_VERSION > 8) {
         return new CollectionContainer<>(numElements);
       } else {
@@ -173,7 +175,8 @@ public ImmutableMapSerializer(Fury fury, Class cls) {
 
     @Override
     public Map newMap(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       if (Platform.JAVA_VERSION > 8) {
         return new JDKImmutableMapContainer(numElements);
       } else {
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializer.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializer.java
index 5a5a1653a2..446eab21d2 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializer.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializer.java
@@ -43,7 +43,7 @@ public Map onMapWrite(MemoryBuffer buffer, T value) {
   @Override
   public T read(MemoryBuffer buffer) {
     Map map = newMap(buffer);
-    readElements(buffer, numElements, map);
+    readElements(buffer, getAndClearNumElements(), map);
     return onMapRead(map);
   }
 
diff --git a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializers.java b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializers.java
index 02f55ee60f..d027a5b1e9 100644
--- a/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializers.java
+++ b/java/fury-core/src/main/java/org/apache/fury/serializer/collection/MapSerializers.java
@@ -63,7 +63,9 @@ public short getXtypeId() {
 
     @Override
     public HashMap newMap(MemoryBuffer buffer) {
-      HashMap hashMap = new HashMap(numElements = buffer.readPositiveVarInt());
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
+      HashMap hashMap = new HashMap(numElements);
       fury.getRefResolver().reference(hashMap);
       return hashMap;
     }
@@ -81,7 +83,9 @@ public short getXtypeId() {
 
     @Override
     public LinkedHashMap newMap(MemoryBuffer buffer) {
-      LinkedHashMap hashMap = new LinkedHashMap(numElements = buffer.readPositiveVarInt());
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
+      LinkedHashMap hashMap = new LinkedHashMap(numElements);
       fury.getRefResolver().reference(hashMap);
       return hashMap;
     }
@@ -99,7 +103,9 @@ public short getXtypeId() {
 
     @Override
     public LazyMap newMap(MemoryBuffer buffer) {
-      LazyMap map = new LazyMap(numElements = buffer.readPositiveVarInt());
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
+      LazyMap map = new LazyMap(numElements);
       fury.getRefResolver().reference(map);
       return map;
     }
@@ -124,7 +130,7 @@ public Map onMapWrite(MemoryBuffer buffer, T value) {
     @SuppressWarnings("unchecked")
     @Override
     public Map newMap(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      setNumElements(buffer.readPositiveVarInt());
       T map;
       Comparator comparator = (Comparator) fury.readRef(buffer);
       if (type == TreeMap.class) {
@@ -237,7 +243,9 @@ public ConcurrentHashMapSerializer(Fury fury, Class<ConcurrentHashMap> type) {
 
     @Override
     public ConcurrentHashMap newMap(MemoryBuffer buffer) {
-      ConcurrentHashMap map = new ConcurrentHashMap(numElements = buffer.readPositiveVarInt());
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
+      ConcurrentHashMap map = new ConcurrentHashMap(numElements);
       fury.getRefResolver().reference(map);
       return map;
     }
@@ -257,7 +265,8 @@ public ConcurrentSkipListMapSerializer(Fury fury, Class<ConcurrentSkipListMap> c
 
     @Override
     public ConcurrentSkipListMap newMap(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
       Comparator comparator = (Comparator) fury.readRef(buffer);
       ConcurrentSkipListMap map = new ConcurrentSkipListMap(comparator);
       fury.getRefResolver().reference(map);
@@ -298,7 +307,7 @@ public Map onMapWrite(MemoryBuffer buffer, EnumMap value) {
 
     @Override
     public EnumMap newMap(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
+      setNumElements(buffer.readPositiveVarInt());
       Class<?> keyType = fury.getClassResolver().readClassInfo(buffer).getCls();
       return new EnumMap(keyType);
     }
@@ -325,6 +334,7 @@ public void write(MemoryBuffer buffer, Map<String, T> value) {
     @Override
     public Map<String, T> read(MemoryBuffer buffer) {
       Map map = newMap(buffer);
+      int numElements = getAndClearNumElements();
       for (int i = 0; i < numElements; i++) {
         map.put(fury.readJavaStringRef(buffer), fury.readRef(buffer));
       }
diff --git a/java/fury-core/src/test/java/org/apache/fury/serializer/collection/ChildContainerSerializersTest.java b/java/fury-core/src/test/java/org/apache/fury/serializer/collection/ChildContainerSerializersTest.java
index cb86a0f190..43a8b88dd5 100644
--- a/java/fury-core/src/test/java/org/apache/fury/serializer/collection/ChildContainerSerializersTest.java
+++ b/java/fury-core/src/test/java/org/apache/fury/serializer/collection/ChildContainerSerializersTest.java
@@ -88,7 +88,7 @@ public void testChildCollection(Fury fury) {
       ChildArrayList<Integer> list = new ChildArrayList<>();
       list.addAll(data);
       list.state = 3;
-      ChildArrayList<Integer> newList = (ChildArrayList) serDe(fury, list);
+      ChildArrayList<Integer> newList = serDe(fury, list);
       Assert.assertEquals(newList, list);
       Assert.assertEquals(newList.state, 3);
       Assert.assertEquals(
diff --git a/java/fury-core/src/test/java/org/apache/fury/serializer/collection/CollectionSerializersTest.java b/java/fury-core/src/test/java/org/apache/fury/serializer/collection/CollectionSerializersTest.java
index 226003e543..b5d443e6f0 100644
--- a/java/fury-core/src/test/java/org/apache/fury/serializer/collection/CollectionSerializersTest.java
+++ b/java/fury-core/src/test/java/org/apache/fury/serializer/collection/CollectionSerializersTest.java
@@ -83,6 +83,22 @@ public void testBasicList(boolean referenceTrackingConfig) {
     serDeCheckSerializer(fury, new LinkedHashSet<>(data), "LinkedHashSet");
   }
 
+  @Test(dataProvider = "referenceTrackingConfig")
+  public void testBasicListNested(boolean referenceTrackingConfig) {
+    Fury fury =
+        Fury.builder()
+            .withLanguage(Language.JAVA)
+            .withRefTracking(referenceTrackingConfig)
+            .requireClassRegistration(false)
+            .build();
+    List<String> data0 = new ArrayList<>(ImmutableList.of("a", "b", "c"));
+    List<List<String>> data = new ArrayList<>(ImmutableList.of(data0, data0));
+    serDeCheckSerializer(fury, data, "ArrayList");
+    serDeCheckSerializer(fury, Arrays.asList("a", "b", "c"), "ArraysAsList");
+    serDeCheckSerializer(fury, new HashSet<>(data), "HashSet");
+    serDeCheckSerializer(fury, new LinkedHashSet<>(data), "LinkedHashSet");
+  }
+
   @Test(dataProvider = "referenceTrackingConfig")
   public void testCollectionGenerics(boolean referenceTrackingConfig) {
     Fury fury =
@@ -494,8 +510,9 @@ public SubListSerializer(Fury fury, Class cls) {
 
     @Override
     public Collection newCollection(MemoryBuffer buffer) {
-      numElements = buffer.readPositiveVarInt();
-      return new ArrayList(numElements);
+      int numElements = buffer.readPositiveVarInt();
+      setNumElements(numElements);
+      return new ArrayList<>(numElements);
     }
   }
 
diff --git a/java/fury-core/src/test/java/org/apache/fury/serializer/collection/MapSerializersTest.java b/java/fury-core/src/test/java/org/apache/fury/serializer/collection/MapSerializersTest.java
index 78826efafb..9b8c9a43e8 100644
--- a/java/fury-core/src/test/java/org/apache/fury/serializer/collection/MapSerializersTest.java
+++ b/java/fury-core/src/test/java/org/apache/fury/serializer/collection/MapSerializersTest.java
@@ -22,6 +22,7 @@
 import static com.google.common.collect.ImmutableList.of;
 import static org.apache.fury.TestUtils.mapOf;
 import static org.apache.fury.collection.Collections.ofArrayList;
+import static org.apache.fury.collection.Collections.ofHashMap;
 import static org.testng.Assert.assertEquals;
 
 import com.google.common.collect.ImmutableMap;
@@ -69,6 +70,20 @@ public void testBasicMap(boolean referenceTrackingConfig) {
     serDeCheckSerializer(fury, new LinkedHashMap<>(data), "LinkedHashMap");
   }
 
+  @Test(dataProvider = "referenceTrackingConfig")
+  public void testBasicMapNested(boolean referenceTrackingConfig) {
+    Fury fury =
+        Fury.builder()
+            .withLanguage(Language.JAVA)
+            .withRefTracking(referenceTrackingConfig)
+            .requireClassRegistration(false)
+            .build();
+    Map<String, Integer> data0 = new HashMap<>(ImmutableMap.of("a", 1, "b", 2));
+    Map<String, Map<String, Integer>> data = ofHashMap("k1", data0, "k2", data0);
+    serDeCheckSerializer(fury, data, "HashMap");
+    serDeCheckSerializer(fury, new LinkedHashMap<>(data), "LinkedHashMap");
+  }
+
   @Test(dataProvider = "referenceTrackingConfig")
   public void testMapGenerics(boolean referenceTrackingConfig) {
     Fury fury =
@@ -333,8 +348,19 @@ public void testStringKeyMapSerializer() {
     // see https://github.com/apache/incubator-fury/issues/1170
     Fury fury = Fury.builder().withRefTracking(true).build();
     fury.registerSerializer(StringKeyMap.class, MapSerializers.StringKeyMapSerializer.class);
-    StringKeyMap<List<String>> list = new StringKeyMap<>();
-    list.put("k1", ofArrayList("a", "b"));
-    serDeCheck(fury, list);
+    {
+      StringKeyMap<List<String>> map = new StringKeyMap<>();
+      map.put("k1", ofArrayList("a", "b"));
+      serDeCheck(fury, map);
+    }
+    {
+      // test nested map
+      StringKeyMap<StringKeyMap<String>> map = new StringKeyMap<>();
+      StringKeyMap<String> map2 = new StringKeyMap<>();
+      map2.put("k-k1", "v1");
+      map2.put("k-k2", "v2");
+      map.put("k1", map2);
+      serDeCheck(fury, map);
+    }
   }
 }
diff --git a/scala/src/main/scala/org/apache/fury/serializer/scala/CollectionSerializer.scala b/scala/src/main/scala/org/apache/fury/serializer/scala/CollectionSerializer.scala
index a1e6be61d7..4aac7ed94c 100644
--- a/scala/src/main/scala/org/apache/fury/serializer/scala/CollectionSerializer.scala
+++ b/scala/src/main/scala/org/apache/fury/serializer/scala/CollectionSerializer.scala
@@ -49,12 +49,14 @@ abstract class AbstractScalaCollectionSerializer[A, T <: Iterable[A]](fury: Fury
 
   override def read(buffer: MemoryBuffer): T = {
     val collection = newCollection(buffer)
+    val numElements = getAndClearNumElements()
     if (numElements != 0) readElements(fury, buffer, collection, numElements)
     onCollectionRead(collection)
   }
 
   override def newCollection(buffer: MemoryBuffer): util.Collection[_] = {
-    numElements = buffer.readPositiveVarInt()
+    val numElements = buffer.readPositiveVarInt()
+    setNumElements(numElements)
     val factory = fury.readRef(buffer).asInstanceOf[Factory[A, T]]
     val builder = factory.newBuilder
     builder.sizeHint(numElements)
diff --git a/scala/src/main/scala/org/apache/fury/serializer/scala/MapSerializer.scala b/scala/src/main/scala/org/apache/fury/serializer/scala/MapSerializer.scala
index f1b3c49f17..fcf6d17957 100644
--- a/scala/src/main/scala/org/apache/fury/serializer/scala/MapSerializer.scala
+++ b/scala/src/main/scala/org/apache/fury/serializer/scala/MapSerializer.scala
@@ -50,12 +50,14 @@ abstract class AbstractScalaMapSerializer[K, V, T](fury: Fury, cls: Class[T])
 
   override def read(buffer: MemoryBuffer): T = {
     val map = newMap(buffer)
-    if (this.numElements != 0) readElements(buffer, numElements, map)
+    val numElements = getAndClearNumElements()
+    if (numElements != 0) readElements(buffer, numElements, map)
     onMapRead(map)
   }
 
   override def newMap(buffer: MemoryBuffer): util.Map[_, _] = {
-    numElements = buffer.readPositiveVarInt()
+    val numElements = buffer.readPositiveVarInt()
+    setNumElements(numElements)
     val factory = fury.readRef(buffer).asInstanceOf[Factory[(K, V), T]]
     val builder = factory.newBuilder
     builder.sizeHint(numElements)