(paimon) branch master updated: [core] Async record reader should only work with .orc not xxxorc (#4037)

[lz...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 7275be7b8 [core] Async record reader should only work with .orc not xxxorc (#4037)
7275be7b8 is described below

commit 7275be7b83d6f1c96793ce2be9d81928bb7ba882
Author: YeJunHao <41...@users.noreply.github.com>
AuthorDate: Thu Aug 22 21:09:34 2024 +0800

    [core] Async record reader should only work with .orc not xxxorc (#4037)
---
 .../src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
index af9b31dd3..afa826bf3 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
@@ -107,7 +107,7 @@ public class KeyValueFileReaderFactory implements FileReaderFactory<KeyValue> {
 
     public RecordReader<KeyValue> createRecordReader(
             long schemaId, String fileName, long fileSize, int level) throws IOException {
-        if (fileSize >= asyncThreshold && fileName.endsWith("orc")) {
+        if (fileSize >= asyncThreshold && fileName.endsWith(".orc")) {
             return new AsyncRecordReader<>(
                     () -> createRecordReader(schemaId, fileName, level, false, 2, fileSize));
         }