Merge pull request #11076 from taosdata/feature/tq
fix submit msg scanner
This commit is contained in:
commit
e149103664
|
@ -157,6 +157,7 @@ SArray* tqRetrieveDataBlock(STqReadHandle* pHandle) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#if 0
|
||||||
int j = 0;
|
int j = 0;
|
||||||
for (int32_t i = 0; i < colNumNeed; i++) {
|
for (int32_t i = 0; i < colNumNeed; i++) {
|
||||||
col_id_t colId = *(col_id_t*)taosArrayGet(pHandle->pColIdList, i);
|
col_id_t colId = *(col_id_t*)taosArrayGet(pHandle->pColIdList, i);
|
||||||
|
@ -183,6 +184,7 @@ SArray* tqRetrieveDataBlock(STqReadHandle* pHandle) {
|
||||||
blockDataEnsureColumnCapacity(&colInfo, numOfRows);
|
blockDataEnsureColumnCapacity(&colInfo, numOfRows);
|
||||||
taosArrayPush(pArray, &colInfo);
|
taosArrayPush(pArray, &colInfo);
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
STSRowIter iter = {0};
|
STSRowIter iter = {0};
|
||||||
tdSTSRowIterInit(&iter, pTschema);
|
tdSTSRowIterInit(&iter, pTschema);
|
||||||
|
|
Loading…
Reference in New Issue