[FLINK-35215][core] Fix the bug when Kryo serialize length is 0

Re-implement to avoid the performance regression
apache · May 8, 2024 · ba2740f · ba2740f
1 parent 6b0f697
commit ba2740f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NoFetchingInput.java b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NoFetchingInput.java
@@ -117,6 +117,10 @@ public void readBytes(byte[] bytes, int offset, int count) throws KryoException
             throw new IllegalArgumentException("bytes cannot be null.");
         }
 
+        if (count == 0) {
+            return;
+        }
+
         try {
             int bytesRead = 0;
             int c;