提交 21fccc2d 编写于 作者: G Ganlin Zhao

fix switchin group issue

上级 7ee05df7
...@@ -903,7 +903,7 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) { ...@@ -903,7 +903,7 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
goto _finished; goto _finished;
} }
} }
// handling post work for a specific group // post work for a specific group
// check if need to interpolate after last datablock // check if need to interpolate after last datablock
// except for fill(next), fill(linear) // except for fill(next), fill(linear)
...@@ -916,6 +916,9 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) { ...@@ -916,6 +916,9 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
// restore initial value for next group // restore initial value for next group
resetTimesliceInfo(pSliceInfo); resetTimesliceInfo(pSliceInfo);
if (checkThresholdReached(pSliceInfo, pOperator->resultInfo.threshold)) {
goto _finished;
}
} }
_finished: _finished:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册