diff --git a/source/libs/stream/inc/streamInt.h b/source/libs/stream/inc/streamInt.h
index d6f6de3de8..1d8fde3a48 100644
--- a/source/libs/stream/inc/streamInt.h
+++ b/source/libs/stream/inc/streamInt.h
@@ -29,7 +29,7 @@ extern "C" {
 #define CHECK_DOWNSTREAM_INTERVAL      100
 #define LAUNCH_HTASK_INTERVAL          100
 #define WAIT_FOR_MINIMAL_INTERVAL      100.00
-#define MAX_RETRY_LAUNCH_HISTORY_TASK  20
+#define MAX_RETRY_LAUNCH_HISTORY_TASK  40
 #define RETRY_LAUNCH_INTERVAL_INC_RATE 1.2
 
 #define MAX_BLOCK_NAME_NUM             1024
diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c
index 3946506238..8b538db7fb 100644
--- a/source/libs/stream/src/streamRecover.c
+++ b/source/libs/stream/src/streamRecover.c
@@ -693,8 +693,7 @@ static void tryLaunchHistoryTask(void* param, void* tmrId) {
         const char* p = streamGetTaskStatusStr(pTask->status.taskStatus);
         int32_t     hTaskId = pHTaskInfo->id.taskId;
         stDebug(
-            "s-task:%s status:%s failed to launch fill-history task:0x%x, retry launch related fill-history task in "
-            "%dms, retryCount:%d",
+            "s-task:%s status:%s failed to launch fill-history task:0x%x, retry launch %dms, retryCount:%d",
             pTask->id.idStr, p, hTaskId, pHTaskInfo->waitInterval, pHTaskInfo->retryTimes);
 
         taosTmrReset(tryLaunchHistoryTask, LAUNCH_HTASK_INTERVAL, pInfo, streamEnv.timer, &pHTaskInfo->pTimer);