Skip to content

Commit 44fe12e

Browse files
committed
[fix][serial] Support selection for v2 schema
1 parent e075712 commit 44fe12e

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

src/coprocessor/coprocessor_v2.cc

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -719,11 +719,13 @@ void CoprocessorV2::GetOriginalColumnIndexes() {
719719

720720
void CoprocessorV2::GetSelectionColumnIndexes() {
721721
if (!coprocessor_.selection_columns().empty()) {
722+
int n = 0;
722723
for (const auto& index : coprocessor_.selection_columns()) {
723724
int i = index;
724-
DINGO_LOG(DEBUG) << "index:" << i;
725+
DINGO_LOG(DEBUG) << "selection index:" << i;
725726
selection_column_indexes_.push_back(original_column_indexes_[i]);
726-
selection_column_indexes_serial_[original_column_indexes_[i]] = i;
727+
selection_column_indexes_serial_[original_column_indexes_[i]] = n;
728+
n++;
727729
}
728730
} else {
729731
DINGO_LOG(DEBUG) << "selection_columns empty()";

0 commit comments

Comments
 (0)