adj stream operator result
This commit is contained in:
parent
afa7d04aaf
commit
f161514c19
|
@ -1319,7 +1319,7 @@ static SSDataBlock* doStreamHashPartition(SOperatorInfo* pOperator) {
|
|||
if (hasRemainTbName(pInfo)) {
|
||||
code = buildStreamCreateTableResult(pOperator);
|
||||
TSDB_CHECK_CODE(code, lino, _end);
|
||||
if (pInfo->pCreateTbRes->info.rows > 0) {
|
||||
if (pInfo->pCreateTbRes && pInfo->pCreateTbRes->info.rows > 0) {
|
||||
return pInfo->pCreateTbRes;
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue