diff --git a/include/libs/stream/tstream.h b/include/libs/stream/tstream.h
index f916e05d52..fd2802058d 100644
--- a/include/libs/stream/tstream.h
+++ b/include/libs/stream/tstream.h
@@ -453,8 +453,8 @@ struct SStreamTask {
   SSHashObj*            pNameMap;
   void*                 pBackend;
   int8_t                subtableWithoutMd5;
+  char                  reserve[256];
   char*                 backendPath;
-  char                  reserve[256 - sizeof(char*)];
 };
 
 typedef int32_t (*startComplete_fn_t)(struct SStreamMeta*);
diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c
index b7b54e2885..cee24bb8dc 100644
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@@ -298,7 +298,6 @@ void tFreeStreamTask(SStreamTask* pTask) {
   taosArrayDestroy(pTask->outputInfo.pNodeEpsetUpdateList);
   pTask->outputInfo.pNodeEpsetUpdateList = NULL;
 
-
   if (pTask->id.idStr != NULL) {
     taosMemoryFree((void*)pTask->id.idStr);
   }
@@ -496,10 +495,13 @@ int32_t streamTaskInit(SStreamTask* pTask, SStreamMeta* pMeta, SMsgCb* pMsgCb, i
 
   if (pTask->chkInfo.pActiveInfo == NULL) {
     code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo);
+    if (code) {
+      stError("s-task:%s failed to create active checkpoint info, code:%s", pTask->id.idStr, tstrerror(code));
+      return code;
+    }
   }
-  code = streamTaskSetBackendPath(pTask);
 
-  return code;
+  return streamTaskSetBackendPath(pTask);
 }
 
 int32_t streamTaskGetNumOfDownstream(const SStreamTask* pTask) {