xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor: remove unused code.

This commit is contained in:
Haojun Liao 2024-09-27 19:23:24 +08:00
parent 75a6645925
commit 70c96783c0
1 changed files with 0 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
source/libs/stream/src/streamExec.c
View File

@ -174,33 +174,6 @@ int32_t streamTaskExecImpl(SStreamTask* pTask, SStreamQueueItem* pItem, int64_t*
taosArrayDestroyEx(pRes, (FDelete)blockDataFreeRes);
return code;
}
// SSDataBlock block = {0};
// const SStreamDataBlock* pRetrieveBlock = (const SStreamDataBlock*)pItem;
//
// int32_t num = taosArrayGetSize(pRetrieveBlock->blocks);
// if (num != 1) {
// stError("s-task:%s invalid retrieve block number:%d, ignore", pTask->id.idStr, num);
// continue;
// }
//
// code = assignOneDataBlock(&block, taosArrayGet(pRetrieveBlock->blocks, 0));
// if (code) {
// stError("s-task:%s failed to copy datablock, code:%s", pTask->id.idStr, tstrerror(code));
// continue;
// }
//
// block.info.type = STREAM_PULL_OVER;
// block.info.childId = pTask->info.selfChildId;
//
// void* p = taosArrayPush(pRes, &block);
// if (p != NULL) {
// numOfBlocks += 1;
// } else {
// stError("s-task:%s failed to add retrieve block", pTask->id.idStr);
// }
//
// stDebug("s-task:%s(child %d) retrieve process completed,QID:0x%" PRIx64 " dump results", pTask->id.idStr,
// pTask->info.selfChildId, pRetrieveBlock->reqId);
}
break;