diff --git a/be/src/vec/exec/format/table/hudi_jni_reader.cpp b/be/src/vec/exec/format/table/hudi_jni_reader.cpp index cb109bf05a2393..1e32e5e1712a30 100644 --- a/be/src/vec/exec/format/table/hudi_jni_reader.cpp +++ b/be/src/vec/exec/format/table/hudi_jni_reader.cpp @@ -72,14 +72,14 @@ HudiJniReader::HudiJniReader(const TFileScanRangeParams& scan_params, } } - if (_hudi_params.hudi_jni_scanner == "hadoop") { - _jni_connector = std::make_unique( - "org/apache/doris/hudi/HadoopHudiJniScanner", params, required_fields); - } else if (_hudi_params.hudi_jni_scanner == "spark") { + if (_hudi_params.hudi_jni_scanner == "spark") { _jni_connector = std::make_unique("org/apache/doris/hudi/HudiJniScanner", params, required_fields); } else { - DCHECK(false) << "Unsupported hudi jni scanner: " << _hudi_params.hudi_jni_scanner; + // _hudi_params.hudi_jni_scanner == "hadoop" + // and default use hadoop hudi jni scanner + _jni_connector = std::make_unique( + "org/apache/doris/hudi/HadoopHudiJniScanner", params, required_fields); } }