fill history

af18afba · liuyao · c7e4aa4f · af18afba
显示空白变更内容
内联并排

Showing with 0 addition and 5 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +0 -5

未找到文件。
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -1820,11 +1820,6 @@ static SSDataBlock* doStreamScan(SOperatorInfo* pOperator) {

  if (pStreamInfo->recoverStep == STREAM_RECOVER_STEP__SCAN1 ||
      pStreamInfo->recoverStep == STREAM_RECOVER_STEP__SCAN2) {
-    if (pInfo->blockRecoverContiCnt > 100) {
-      pInfo->blockRecoverTotCnt += pInfo->blockRecoverContiCnt;
-      pInfo->blockRecoverContiCnt = 0;
-      return NULL;
-    }

    switch (pInfo->scanMode) {
      case STREAM_SCAN_FROM_RES: {