diff --git a/be/src/vec/exec/format/avro/avro_jni_reader.cpp b/be/src/vec/exec/format/avro/avro_jni_reader.cpp index 0877e8406b..ec08c58d18 100644 --- a/be/src/vec/exec/format/avro/avro_jni_reader.cpp +++ b/be/src/vec/exec/format/avro/avro_jni_reader.cpp @@ -43,7 +43,7 @@ AvroJNIReader::AvroJNIReader(RuntimeProfile* profile, const TFileScanRangeParams AvroJNIReader::~AvroJNIReader() = default; Status AvroJNIReader::get_next_block(Block* block, size_t* read_rows, bool* eof) { - RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof)); + RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof)); if (*eof) { RETURN_IF_ERROR(_jni_connector->close()); } diff --git a/be/src/vec/exec/format/jni_reader.cpp b/be/src/vec/exec/format/jni_reader.cpp index 02002ed256..625c79ffff 100644 --- a/be/src/vec/exec/format/jni_reader.cpp +++ b/be/src/vec/exec/format/jni_reader.cpp @@ -63,7 +63,7 @@ MockJniReader::MockJniReader(const std::vector& file_slot_descs } Status MockJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) { - RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof)); + RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof)); if (*eof) { RETURN_IF_ERROR(_jni_connector->close()); } 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 bd6b40f3f1..1cba7da7c6 100644 --- a/be/src/vec/exec/format/table/hudi_jni_reader.cpp +++ b/be/src/vec/exec/format/table/hudi_jni_reader.cpp @@ -80,7 +80,7 @@ HudiJniReader::HudiJniReader(const TFileScanRangeParams& scan_params, } Status HudiJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) { - RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof)); + RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof)); if (*eof) { RETURN_IF_ERROR(_jni_connector->close()); } diff --git a/be/src/vec/exec/format/table/max_compute_jni_reader.cpp b/be/src/vec/exec/format/table/max_compute_jni_reader.cpp index 2884c41310..152b957127 100644 --- a/be/src/vec/exec/format/table/max_compute_jni_reader.cpp +++ b/be/src/vec/exec/format/table/max_compute_jni_reader.cpp @@ -81,7 +81,7 @@ MaxComputeJniReader::MaxComputeJniReader(const MaxComputeTableDescriptor* mc_des } Status MaxComputeJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) { - RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof)); + RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof)); if (*eof) { RETURN_IF_ERROR(_jni_connector->close()); } diff --git a/be/src/vec/exec/format/table/paimon_reader.cpp b/be/src/vec/exec/format/table/paimon_reader.cpp index 4d6cfc96b5..28282a2bf9 100644 --- a/be/src/vec/exec/format/table/paimon_reader.cpp +++ b/be/src/vec/exec/format/table/paimon_reader.cpp @@ -70,7 +70,7 @@ PaimonJniReader::PaimonJniReader(const std::vector& file_slot_d } Status PaimonJniReader::get_next_block(Block* block, size_t* read_rows, bool* eof) { - RETURN_IF_ERROR(_jni_connector->get_nex_block(block, read_rows, eof)); + RETURN_IF_ERROR(_jni_connector->get_next_block(block, read_rows, eof)); if (*eof) { RETURN_IF_ERROR(_jni_connector->close()); } diff --git a/be/src/vec/exec/jni_connector.cpp b/be/src/vec/exec/jni_connector.cpp index f0494f931a..26b66f48ac 100644 --- a/be/src/vec/exec/jni_connector.cpp +++ b/be/src/vec/exec/jni_connector.cpp @@ -112,7 +112,7 @@ Status JniConnector::init( return Status::OK(); } -Status JniConnector::get_nex_block(Block* block, size_t* read_rows, bool* eof) { +Status JniConnector::get_next_block(Block* block, size_t* read_rows, bool* eof) { // Call org.apache.doris.common.jni.JniScanner#getNextBatchMeta // return the address of meta information JNIEnv* env = nullptr; diff --git a/be/src/vec/exec/jni_connector.h b/be/src/vec/exec/jni_connector.h index 194370faf7..ed282fc0c4 100644 --- a/be/src/vec/exec/jni_connector.h +++ b/be/src/vec/exec/jni_connector.h @@ -234,7 +234,7 @@ public: * | data column start address of the variable length column-B | * | ... | */ - Status get_nex_block(Block* block, size_t* read_rows, bool* eof); + Status get_next_block(Block* block, size_t* read_rows, bool* eof); /** * Get performance metrics from java scanner