提交 2e0b4236 编写于 作者: D dapan1121

fix: hash join row index issue

上级 efbb6cb1
...@@ -369,9 +369,6 @@ static FORCE_INLINE void appendHJoinResToBlock(struct SOperatorInfo* pOperator, ...@@ -369,9 +369,6 @@ static FORCE_INLINE void appendHJoinResToBlock(struct SOperatorInfo* pOperator,
pRes->info.rows = resNum; pRes->info.rows = resNum;
pCtx->rowRemains = pCtx->pBuildRow ? true : false; pCtx->rowRemains = pCtx->pBuildRow ? true : false;
if (!pCtx->rowRemains) {
pCtx->probeIdx++;
}
} }
...@@ -423,8 +420,8 @@ static void doHashJoinImpl(struct SOperatorInfo* pOperator) { ...@@ -423,8 +420,8 @@ static void doHashJoinImpl(struct SOperatorInfo* pOperator) {
} }
} }
for (int32_t i = pCtx->probeIdx; i < pCtx->pProbeData->info.rows; ++i) { for (; pCtx->probeIdx < pCtx->pProbeData->info.rows; ++pCtx->probeIdx) {
copyKeyColsDataToBuf(pProbe, i, &bufLen); copyKeyColsDataToBuf(pProbe, pCtx->probeIdx, &bufLen);
SGroupData* pGroup = tSimpleHashGet(pJoin->pKeyHash, pProbe->keyData, bufLen); SGroupData* pGroup = tSimpleHashGet(pJoin->pKeyHash, pProbe->keyData, bufLen);
if (pGroup) { if (pGroup) {
pCtx->pBuildRow = pGroup->rows; pCtx->pBuildRow = pGroup->rows;
......
...@@ -797,7 +797,7 @@ static int32_t createTableListInfoFromParam(SOperatorInfo* pOperator) { ...@@ -797,7 +797,7 @@ static int32_t createTableListInfoFromParam(SOperatorInfo* pOperator) {
return TSDB_CODE_INVALID_PARA; return TSDB_CODE_INVALID_PARA;
} }
qDebug("add total %d dynamic tables to scan, exist num:%d", num, taosArrayGetSize(pListInfo->pTableList)); qDebug("add total %d dynamic tables to scan, exist num:%" PRId64, num, (int64_t)taosArrayGetSize(pListInfo->pTableList));
pListInfo->oneTableForEachGroup = true; pListInfo->oneTableForEachGroup = true;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册