fix(stream): disable error injection.

2025-02-22 14:19:44 +08:00 · 2025-02-22 14:19:44 +08:00 · a8d50f28a6
parent 6c92474afd
commit a8d50f28a6
1 changed files with 2 additions and 2 deletions
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@ -124,10 +124,10 @@ static void doStartScanWal(void* param, void* tmrId) {

  tqTrace("vgId:%d create msg to start wal scan, numOfTasks:%d", vgId, numOfTasks);

-  // #if 0
+   #if 0
  //  wait for the vnode is freed, and invalid read may occur.
  taosMsleep(10000);
-  // #endif
+   #endif

  code = streamTaskSchedTask(&pParam->msgCb, vgId, 0, 0, STREAM_EXEC_T_EXTRACT_WAL_DATA);
  if (code) {