diff --git a/source/libs/index/src/index.c b/source/libs/index/src/index.c
index f41b5525f3..d7e5d87e80 100644
--- a/source/libs/index/src/index.c
+++ b/source/libs/index/src/index.c
@@ -25,8 +25,10 @@
 #include "tref.h"
 #include "tsched.h"
 
-#define INDEX_NUM_OF_THREADS 5
-#define INDEX_QUEUE_SIZE     200
+#define INDEX_NUM_OF_THREADS     5
+#define INDEX_MAX_NUM_OF_THREADS 10
+
+#define INDEX_QUEUE_SIZE 200
 
 #define INDEX_DATA_BOOL_NULL      0x02
 #define INDEX_DATA_TINYINT_NULL   0x80
@@ -61,6 +63,7 @@ static void indexDestroy(void* sIdx);
 void indexInit(int32_t threadNum) {
   indexThreads = threadNum;
   if (indexThreads <= 1) indexThreads = INDEX_NUM_OF_THREADS;
+  if (indexThreads >= INDEX_MAX_NUM_OF_THREADS) indexThreads = INDEX_MAX_NUM_OF_THREADS;
 }
 void indexEnvInit() {
   // refactor later