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 1888d2a37c71e4..9188dfd4c7a749 100644 --- a/be/src/vec/exec/format/table/hudi_jni_reader.cpp +++ b/be/src/vec/exec/format/table/hudi_jni_reader.cpp @@ -72,16 +72,10 @@ 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); - // } - 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; - } + // set spark jni scanner as default + // TODO: add hadoop jni scanner after hadoop client is ready + _jni_connector = std::make_unique("org/apache/doris/hudi/HudiJniScanner", params, + required_fields); } Status HudiJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) {