diff --git a/src/benchInsertMix.c b/src/benchInsertMix.c
index 5bd09a09..55d74dd3 100644
--- a/src/benchInsertMix.c
+++ b/src/benchInsertMix.c
@@ -48,13 +48,13 @@ typedef struct {
   // need generate count , calc from stb->insertRows * ratio
   uint64_t genCnt[MCNT];
 
-  // status aleady done count
+  // status already done count
   uint64_t doneCnt[MCNT];
 
   // task out from batch to list buffer
   TSKEY* buf[MCNT];
 
-  // bufer cnt
+  // buffer cnt
   uint64_t capacity[MCNT]; // capacity size for buf
   uint64_t bufCnt[MCNT];   // current valid cnt in buf
 
@@ -124,7 +124,7 @@ void mixRatioExit(SMixRatio* mix) {
 //  --------------------- util ----------------
 //
 
-// return true can do execute delelte sql
+// return true can do execute delete sql
 bool needExecDel(SMixRatio* mix) {
   if (mix->genCnt[MDEL] == 0 || mix->doneCnt[MDEL] >= mix->genCnt[MDEL]) {
     return false;
@@ -708,7 +708,7 @@ bool checkCorrect(threadInfo* info, SDataBase* db, SSuperTable* stb, char* tbNam
     return false;
   }
   if (count != calcCount) {
-    errorPrint("checkCorrect query count unexpect, tbname=%s query=%" PRId64 " expect=%" PRId64, tbName, count,
+    errorPrint("checkCorrect query count unexpected, tbname=%s query=%" PRId64 " expect=%" PRId64, tbName, count,
                calcCount);
 
     return false;
@@ -735,7 +735,7 @@ bool checkCorrect(threadInfo* info, SDataBase* db, SSuperTable* stb, char* tbNam
 
   // check count correct
   if (ts != lastTs) {
-    errorPrint("checkCorrect query last unexpect, tbname=%s query last=%" PRId64 " expect=%" PRId64, tbName, ts,
+    errorPrint("checkCorrect query last unexpected, tbname=%s query last=%" PRId64 " expect=%" PRId64, tbName, ts,
                lastTs);
     return false;
   }
diff --git a/src/benchJsonOpt.c b/src/benchJsonOpt.c
index da4de9be..41592b42 100644
--- a/src/benchJsonOpt.c
+++ b/src/benchJsonOpt.c
@@ -322,7 +322,7 @@ static int getDatabaseInfo(tools_cJSON *dbinfos, int index) {
             SDbCfg* cfg = benchCalloc(1, sizeof(SDbCfg), true);
             cfg->name = cfg_object->string;
 
-            // get duration vallue
+            // get duration value
             if (0 == strcasecmp(cfg_object->string, "duration")) {
                 database->durMinute = getDurationVal(cfg_object);
             }
@@ -707,7 +707,7 @@ static int getStableInfo(tools_cJSON *dbinfos, int index) {
                 superTable->startTimestamp =
                     toolsGetTimestamp(database->precision);
                 superTable->useNow = true;
-                //  fill time with now conflict wih check_sql
+                //  fill time with now conflict with check_sql
                 g_arguments->check_sql = false;
             } else {
                 if (toolsParseTime(ts->valuestring,