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

fix: invalid read issue

This commit is contained in:
dapan1121 2024-04-15 09:52:35 +08:00
parent 6f8040c754
commit 168769830f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/executor/src/hashjoinoperator.c
View File

@ -145,7 +145,7 @@ static int64_t hJoinGetRowsNumOfKeyHash(SSHashObj* pHash) {
while (NULL != (pGroup = tSimpleHashIterate(pHash, pGroup, &iter))) { while (NULL != (pGroup = tSimpleHashIterate(pHash, pGroup, &iter))) {
int32_t* pKey = tSimpleHashGetKey(pGroup, NULL); int32_t* pKey = tSimpleHashGetKey(pGroup, NULL);
int64_t rows = hJoinGetSingleKeyRowsNum(pGroup->rows); int64_t rows = hJoinGetSingleKeyRowsNum(pGroup->rows);
qTrace("build_key:%d, rows:%" PRId64, *pKey, rows); //qTrace("build_key:%d, rows:%" PRId64, *pKey, rows);
rowsNum += rows; rowsNum += rows;
} }
@ -906,7 +906,7 @@ static int32_t hJoinBuildHash(struct SOperatorInfo* pOperator, bool* queryDone)
*queryDone = true; *queryDone = true;
} }
qTrace("build table rows:%" PRId64, hJoinGetRowsNumOfKeyHash(pJoin->pKeyHash)); //qTrace("build table rows:%" PRId64, hJoinGetRowsNumOfKeyHash(pJoin->pKeyHash));
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }