Update executorMain.c
This commit is contained in:
parent
b1f3428c05
commit
ac2b13740b
|
@ -348,11 +348,9 @@ int32_t qStreamPrepareScan(qTaskInfo_t tinfo, const STqOffsetVal* pOffset) {
|
||||||
int32_t tableSz = taosArrayGetSize(pTaskInfo->tableqinfoList.pTableList);
|
int32_t tableSz = taosArrayGetSize(pTaskInfo->tableqinfoList.pTableList);
|
||||||
|
|
||||||
#ifndef NDEBUG
|
#ifndef NDEBUG
|
||||||
int64_t previousUid =
|
|
||||||
((STableKeyInfo*)taosArrayGet(pTaskInfo->tableqinfoList.pTableList, pTableScanInfo->currentTable))->uid;
|
|
||||||
|
|
||||||
qDebug("switch to next table %ld (cursor %d), previous table %ld, %ld rows returned", uid,
|
qDebug("switch to next table %ld (cursor %d), %ld rows returned", uid,
|
||||||
pTableScanInfo->currentTable, previousUid, pInfo->pTableScanOp->resultInfo.totalRows);
|
pTableScanInfo->currentTable, pInfo->pTableScanOp->resultInfo.totalRows);
|
||||||
pInfo->pTableScanOp->resultInfo.totalRows = 0;
|
pInfo->pTableScanOp->resultInfo.totalRows = 0;
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue