This commit is contained in:
Liu Jicong 2022-03-22 18:58:43 +08:00
parent d3104e78ec
commit afe8439095
2 changed files with 4 additions and 2 deletions

View File

@ -215,10 +215,12 @@ int main(int argc, char* argv[]) {
printf("env init\n"); printf("env init\n");
code = init_env(); code = init_env();
} }
create_topic(); create_stream();
#if 0
tmq_t* tmq = build_consumer(); tmq_t* tmq = build_consumer();
tmq_list_t* topic_list = build_topic_list(); tmq_list_t* topic_list = build_topic_list();
/*perf_loop(tmq, topic_list);*/ /*perf_loop(tmq, topic_list);*/
/*basic_consume_loop(tmq, topic_list);*/ /*basic_consume_loop(tmq, topic_list);*/
sync_consume_loop(tmq, topic_list); sync_consume_loop(tmq, topic_list);
#endif
} }

View File

@ -4873,7 +4873,7 @@ static SSDataBlock* doStreamBlockScan(SOperatorInfo *pOperator, bool* newgroup)
SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo; SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo;
SStreamBlockScanInfo* pInfo = pOperator->info; SStreamBlockScanInfo* pInfo = pOperator->info;
if (pInfo->blockType == STREAM_DATA_TYPE_SSDAT_BLOCK) { if (pInfo->blockType == STREAM_DATA_TYPE_SSDATA_BLOCK) {
if (pInfo->blockValid) { if (pInfo->blockValid) {
pInfo->blockValid = false; // this block can only be used once. pInfo->blockValid = false; // this block can only be used once.
return pInfo->pRes; return pInfo->pRes;