fix interval issue

4b9190ab · wpan · 99aca608 · 4b9190ab
显示空白变更内容
内联并排

Showing with 2 addition and 1 deletion

src/query/src/qExecutor.c src/query/src/qExecutor.c +2 -1

未找到文件。
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -1304,7 +1304,8 @@ static void hashIntervalAgg(SOperatorInfo* pOperatorInfo, SResultRowInfo* pResul
        j++;
      }

-      for(; pResultRowInfo->pResult[j] != pResultRowInfo->current; ++j) {
+      SResultRow* current = pResultRowInfo->current;
+      for(; pResultRowInfo->pResult[j] != current && j < pResultRowInfo->size; ++j) {
      SResultRow* pRes = pResultRowInfo->pResult[j];
      if (pRes->closed) {
        assert(resultRowInterpolated(pRes, RESULT_ROW_START_INTERP) && resultRowInterpolated(pRes, RESULT_ROW_END_INTERP));