make sure validate column ok first

pull/1191/head
ms_yan 5 years ago
parent e8deacea3c
commit 30739001c8

@ -79,7 +79,7 @@ Status ConcatOp::operator()() {
if (buf->eof() || buf->eoe()) { if (buf->eof() || buf->eoe()) {
RETURN_IF_NOT_OK(child_[i]->GetNextBuffer(&buf)); RETURN_IF_NOT_OK(child_[i]->GetNextBuffer(&buf));
} }
// 2. Do varification as for column name, column data type and rank of column data // 2. Do verification as for column name, column data type and rank of column data
RETURN_IF_NOT_OK(Verify(i, buf)); RETURN_IF_NOT_OK(Verify(i, buf));
// 3. Put the data into output_connector // 3. Put the data into output_connector

@ -292,7 +292,7 @@ Status MapOp::WorkerEntryInit(const DataBuffer *in_buf) {
// Before we continue, issue a sanity check to make sure the input columns from user and the incoming // Before we continue, issue a sanity check to make sure the input columns from user and the incoming
// columns from child are correct // columns from child are correct
this->ValidateInColumns(current_name_id_map); RETURN_IF_NOT_OK(this->ValidateInColumns(current_name_id_map));
// initialize keep_input_columns, true means to keep the column. // initialize keep_input_columns, true means to keep the column.
keep_input_columns_.resize(num_cols, true); keep_input_columns_.resize(num_cols, true);

Loading…
Cancel
Save