diff --git a/include/libs/executor/executor.h b/include/libs/executor/executor.h
index caa8f0bc36..4d53f40176 100644
--- a/include/libs/executor/executor.h
+++ b/include/libs/executor/executor.h
@@ -46,7 +46,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void *msg, void* streamReadHandle);
  * @param input
  * @return
  */
-int32_t     qSetStreamInput(qTaskInfo_t tinfo, const void* input);
+int32_t qSetStreamInput(qTaskInfo_t tinfo, const void* input);
 
 /**
  * Update the table id list, add or remove.
@@ -56,7 +56,7 @@ int32_t     qSetStreamInput(qTaskInfo_t tinfo, const void* input);
  * @param isAdd
  * @return
  */
-int32_t qUpdateTQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd);
+int32_t qUpdateQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd);
 
  /**
   * Create the exec task object according to task json
diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c
index 29e60c8e91..e7e6dd7129 100644
--- a/source/libs/executor/src/executor.c
+++ b/source/libs/executor/src/executor.c
@@ -91,7 +91,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void* msg, void* streamReadHandle) {
   return pTaskInfo;
 }
 
-int32_t qUpdateTQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd) {
+int32_t qUpdateQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd) {
   SExecTaskInfo* pTaskInfo = (SExecTaskInfo* )tinfo;
 
   // traverse to the streamscan node to add this table id