[test] Fix flaky test VectoredReadUtilsTest.testRandom

apache · May 30, 2024 · 71fbe24 · 71fbe24
1 parent 2da5098
commit 71fbe24
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/fs/VectoredReadUtils.java b/paimon-common/src/main/java/org/apache/paimon/fs/VectoredReadUtils.java
@@ -53,8 +53,8 @@ public static void readVectored(VectoredReadable readable, List<? extends FileRa
 
         int parallelism = readable.parallelismForVectorReads();
 
-        if (combinedRanges.size() == 1) {
-            fallbackToReadSequence(readable, sortRanges);
+        if (combinedRanges.size() == 1 && readable instanceof SeekableInputStream) {
+            fallbackToReadSequence((SeekableInputStream) readable, sortRanges);
             return;
         }
 
@@ -78,8 +78,7 @@ public static void readVectored(VectoredReadable readable, List<? extends FileRa
     }
 
     private static void fallbackToReadSequence(
-            VectoredReadable readable, List<? extends FileRange> ranges) throws IOException {
-        SeekableInputStream in = (SeekableInputStream) readable;
+            SeekableInputStream in, List<? extends FileRange> ranges) throws IOException {
         for (FileRange range : ranges) {
             byte[] bytes = new byte[range.getLength()];
             in.seek(range.getOffset());