refactor: injection error.

2024-11-16 01:56:33 +08:00 · 2024-11-16 01:56:33 +08:00 · 55239964a9
parent 20ad165ae3
commit 55239964a9
1 changed files with 4 additions and 0 deletions
--- a/source/libs/stream/src/streamCheckpoint.c
+++ b/source/libs/stream/src/streamCheckpoint.c
@ -362,6 +362,10 @@ int32_t streamProcessCheckpointTriggerBlock(SStreamTask* pTask, SStreamDataBlock
    }
  }

+#if 0
+  taosMsleep(20*1000);
+#endif
+
  if (taskLevel == TASK_LEVEL__SOURCE) {
    int8_t type = pTask->outputInfo.type;
    pActiveInfo->allUpstreamTriggerRecv = 1;