From 8e0afd275d364b368da98bdc5cbe2f71628c3f9b Mon Sep 17 00:00:00 2001 From: kakachen Date: Thu, 4 Sep 2025 22:54:25 +0800 Subject: [PATCH] [fix](paimon) Fix paimon native table don't use late materialization. --- be/src/vec/exec/scan/vfile_scanner.cpp | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/be/src/vec/exec/scan/vfile_scanner.cpp b/be/src/vec/exec/scan/vfile_scanner.cpp index d6059347f026cf..6d7dac8d57302a 100644 --- a/be/src/vec/exec/scan/vfile_scanner.cpp +++ b/be/src/vec/exec/scan/vfile_scanner.cpp @@ -721,9 +721,6 @@ Status VFileScanner::_get_next_reader() { // for compatibility, if format_type is not set in range, use the format type of params TFileFormatType::type format_type = range.__isset.format_type ? range.format_type : _params->format_type; - // JNI reader can only push down column value range - bool push_down_predicates = - !_is_load && _params->format_type != TFileFormatType::FORMAT_JNI; // for compatibility, this logic is deprecated in 3.1 if (format_type == TFileFormatType::FORMAT_JNI && range.__isset.table_format_params) { if (range.table_format_params.table_format_type == "paimon" && @@ -739,6 +736,8 @@ Status VFileScanner::_get_next_reader() { } } } + // JNI reader can only push down column value range + bool push_down_predicates = !_is_load && format_type != TFileFormatType::FORMAT_JNI; bool need_to_get_parsed_schema = false; switch (format_type) { case TFileFormatType::FORMAT_JNI: {