refactor: do some internal refactor.

ccc86f99 · Haojun Liao · 87deb36f · ccc86f99
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamExec.c source/libs/stream/src/streamExec.c +1 -1

未找到文件。
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -18,7 +18,7 @@
 // maximum allowed processed block batches. One block may include several submit blocks
 #define MAX_STREAM_EXEC_BATCH_NUM 32
 #define MIN_STREAM_EXEC_BATCH_NUM 8
-#define MAX_STREAM_RESULT_DUMP_THRESHOLD  1000
+#define MAX_STREAM_RESULT_DUMP_THRESHOLD  100

 static int32_t updateCheckPointInfo (SStreamTask* pTask);