database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](insert) Fix test_group_commit_stream_load and add more regression in test_group_commit_http_stream (#24954)

Browse Source
This commit is contained in:
meiyi
2023-10-03 20:56:24 +08:00
committed by GitHub
parent c298b1ca1a
commit 4ce5213b1c
4 changed files with 46 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/runtime/group_commit_mgr.cpp
View File

@ -595,10 +595,10 @@ Status GroupCommitMgr::_group_commit_stream_load(std::shared_ptr<StreamLoadConte
ctx->label = load_block_queue->label;
ctx->txn_id = load_block_queue->txn_id;
}
RETURN_IF_ERROR(load_block_queue->add_block(future_block));
if (future_block->rows() > 0) {
future_blocks.emplace_back(future_block);
}
RETURN_IF_ERROR(load_block_queue->add_block(future_block));
first = false;
}
ctx->number_unselected_rows = runtime_state->num_rows_load_unselected();