File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1463,12 +1463,12 @@ int ObVecIndexAsyncTask::process_data_for_index(ObPluginVectorIndexAdaptor &adap
14631463 ObString vector_str;
14641464 float *vector_ptr = nullptr ;
14651465 const int64_t vec_col_idx = 0 ; // ObPluginVectorIndexUtils::read_local_tablet get from INDEX_TYPE_IS_NOT output vector column first
1466+ blocksstable::ObDatumRow *vector_row = datum_row;
14661467 int32_t vector_column_pos = is_hybrid_index? data_table_rowkey_count + 1 : vec_col_idx;
14671468 if (is_hybrid_index && !adaptor.get_is_need_vid ()) {
1468- // hybrid without vid_rowkey_tbl: [pk(vid)] [vector]
1469- vector_column_pos = 1 ;
1469+ // hybrid without vid_rowkey_tbl: [pk(vid)] [part_key] [ vector]
1470+ vector_column_pos = vector_row-> get_column_count () - 1 ;
14701471 }
1471- blocksstable::ObDatumRow *vector_row = datum_row;
14721472 if (OB_FAIL (ret)) {
14731473 } else if (vector_row->storage_datums_ [vector_column_pos].is_null () || vector_row->storage_datums_ [vector_column_pos].is_nop ()) { // skip null row
14741474 } else if (FALSE_IT (vector_str = vector_row->storage_datums_ [vector_column_pos].get_string ())) {
You can’t perform that action at this time.
0 commit comments