refactor(stream): disable error injection.

This commit is contained in:
Haojun Liao 2025-02-20 17:39:46 +08:00
parent 22c05fde79
commit 3f70661dcf
1 changed files with 2 additions and 2 deletions

View File

@ -824,10 +824,10 @@ static int32_t doStreamExecTask(SStreamTask* pTask) {
// dispatch checkpoint msg to all downstream tasks
int32_t type = pInput->type;
if (type == STREAM_INPUT__CHECKPOINT_TRIGGER) {
#if 0
// Injection error: for automatic kill long trans test
taosMsleep(50*1000);
#endif
code = streamProcessCheckpointTriggerBlock(pTask, (SStreamDataBlock*)pInput);
if (code != 0) {
stError("s-task:%s failed to process checkpoint-trigger block, code:%s", pTask->id.idStr, tstrerror(code));