提交 c321a639 编写于 作者: X xywang

[TS-676]<fix>: fixed coredump when 'group by' was used

上级 b1d7c094
...@@ -5780,6 +5780,11 @@ static SSDataBlock* doProjectOperation(void* param, bool* newgroup) { ...@@ -5780,6 +5780,11 @@ static SSDataBlock* doProjectOperation(void* param, bool* newgroup) {
} }
} }
if (pOperator->status == OP_EXEC_DONE) {
*newgroup = false;
return NULL;
}
while(1) { while(1) {
bool prevVal = *newgroup; bool prevVal = *newgroup;
...@@ -5792,7 +5797,7 @@ static SSDataBlock* doProjectOperation(void* param, bool* newgroup) { ...@@ -5792,7 +5797,7 @@ static SSDataBlock* doProjectOperation(void* param, bool* newgroup) {
//assert(*newgroup == false); //assert(*newgroup == false);
*newgroup = prevVal; *newgroup = prevVal;
setQueryStatus(pRuntimeEnv, QUERY_COMPLETED); doSetOperatorCompleted(pOperator);
break; break;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册