提交 877886cc 编写于 作者: H Haojun Liao

Merge remote-tracking branch 'origin/fix/test_1x' into fix/test_1x

...@@ -2316,7 +2316,7 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) { ...@@ -2316,7 +2316,7 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) {
STaskStatusEntry *p = taosArrayGet(req.pTaskStatus, i); STaskStatusEntry *p = taosArrayGet(req.pTaskStatus, i);
int64_t k[2] = {p->streamId, p->taskId}; int64_t k[2] = {p->streamId, p->taskId};
int32_t* index = taosHashGet(execNodeList.pTaskMap, &k, sizeof(k)); int32_t *index = taosHashGet(execNodeList.pTaskMap, &k, sizeof(k));
if (index == NULL) { if (index == NULL) {
continue; continue;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册