fix recall

2026-01-28 13:43:24 +08:00
parent a2aa627b1e
commit fe8ba6fad9
1 changed files with 4 additions and 2 deletions
--- a/json/create_json.cpp
+++ b/json/create_json.cpp
@@ -2288,8 +2288,10 @@ int transfer_json_block_data(char v_wiring_type[], json_block_data *data) //json
 							kafka_data_list_mutex.unlock(); //解锁
 							longjumpflag = true;
 						}
-						if (longjumpflag == true || shortjumpflag == true) {
-							return 1;
+						if (typeofdata == false) {//不合并则处理完闪变就不处理其他数据
+							if (longjumpflag == true || shortjumpflag == true) {
+								return 1;
+							}
 						}
 						//return 1; //结束该函数，停止后续代码执行
 					} //②-②历史闪变数据解析结束！--------------------------------