114 commits

Author	SHA1	Message	Date
wangjiaming0909	9a92c136ce	fix drop child table with tsma	2024-11-08 09:47:47 +08:00
54liuyao	ba31bf2c52	Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837	2024-11-06 09:42:50 +08:00
Haojun Liao	693aacb8cb	refactor: always successfully put the retrieve msg even though the input queue is full already.	2024-11-05 17:15:19 +08:00
Haojun Liao	c0932d419d	fix(stream): fix error in pause/resume for force_window_close	2024-10-28 18:07:11 +08:00
lyh250-666	df147c60b0	enh:modify error code passing	2024-09-23 08:58:10 +08:00
Haojun Liao	a33015e712	refactor: pass error code to invoker.	2024-09-13 19:35:02 +08:00
lyh250-666	6cbb0cf172	enh:modify error code passing libs/	2024-09-11 09:58:41 +08:00
Haojun Liao	277528996e	fix(stream): handle continuous retrieve during checkpoint procedure.	2024-09-05 16:04:36 +08:00
Haojun Liao	fb8867f403	refactor: remove assert.	2024-08-29 19:55:09 +08:00
Haojun Liao	b6084e64ce	refactor: remove assert in stream module.	2024-08-21 10:00:35 +08:00
Haojun Liao	59d190508d	fix(query):check return code	2024-08-06 16:46:40 +08:00
Haojun Liao	715b6428aa	fix(stream): update the merge result check.	2024-07-31 16:33:44 +08:00
Haojun Liao	2ca6726922	refactor: check return value for each function.	2024-07-18 22:52:32 +08:00
Haojun Liao	b35d107bf9	refactor: check return value for each function.	2024-07-17 18:55:04 +08:00
Hongze Cheng	64363627fe	enh: refact tqueue code	2024-07-16 17:30:32 +08:00
Haojun Liao	ee4e4c0e6d	refactor: do some internal refactor.	2024-05-31 09:17:20 +08:00
Haojun Liao	27ac6ca16e	fix(stream): desc the ref for checkpoint-trigger timer.	2024-05-29 14:12:14 +08:00
Haojun Liao	0c61fb20d6	fix(stream): check if outputQ is full before execute the scan history task. if it is full, idle for 5 sec.	2024-05-23 17:22:29 +08:00
Haojun Liao	bbd423f666	refactor: do some internal refactor.	2024-05-07 09:46:12 +08:00
Haojun Liao	7ad7ef7cfc	refactor: do some internal refactor.	2024-05-06 17:03:41 +08:00
Haojun Liao	8b53f76691	fix(stream): discard the repeatly recv checkpoint-source msg.	2024-04-26 15:56:34 +08:00
Haojun Liao	8bdd43c305	fix(stream): wait for 50ms when no token in bucket for sink task.	2024-04-16 14:42:21 +08:00
Haojun Liao	3236ef7bae	feat(stream): return the stream source task exec delay, and do some internal refactor.	2024-02-02 11:26:47 +08:00
Haojun Liao	143e6a13af	fix(stream): fix deadlock in pause.	2024-01-15 14:37:24 +08:00
Haojun Liao	b36cc97236	fix(stream): close the inputQ of the related stream task when the fill-history task recv the trans-state msg from upstream.	2024-01-12 10:44:49 +08:00
Haojun Liao	9703018f56	fix(stream): add checkpoint status check.	2024-01-11 16:47:51 +08:00
Haojun Liao	d4fd544c74	refactor: remove sleep.	2024-01-11 15:18:11 +08:00
Haojun Liao	bb9edde79e	fix(stream): add some logs.	2024-01-08 11:33:54 +08:00
Haojun Liao	522e688387	fix(stream): check if in restart procedure in call back.	2024-01-05 22:16:58 +08:00
Haojun Liao	185fa75376	enh(stream): add task into timer to be idle during exec when the corresponding output queue is full.	2024-01-03 17:59:42 +08:00
Haojun Liao	1a1319908d	refactor: do some internal refactor.	2023-11-23 14:25:52 +08:00
Haojun Liao	9f8a63099c	fix(stream): fix error in generating token in bucket.	2023-11-20 15:26:50 +08:00
Haojun Liao	e1de1de421	fix(stream): fix the invalid free.	2023-11-11 15:40:07 +08:00
Haojun Liao	0463c0d755	refactor: wait for a while when no quota available.	2023-11-11 15:38:41 +08:00
Haojun Liao	22808ce1b7	fix(stream): update the fill-time for quota limitation.	2023-11-11 15:38:32 +08:00
Haojun Liao	26b96b149d	refactor: wait for a while when no quota available.	2023-11-07 18:43:35 +08:00
Haojun Liao	0979ff944b	fix(stream): update the fill-time for quota limitation.	2023-11-07 18:43:34 +08:00
Haojun Liao	2bdde122fc	refactor: wait a while when no token available.	2023-11-07 18:43:34 +08:00
Haojun Liao	ed0c580d11	refactor: do some internal refactor.	2023-11-07 17:04:55 +08:00
Haojun Liao	e13f003b90	refactor: do some internal refactor.	2023-11-05 01:23:23 +08:00
Haojun Liao	c7285c0ede	fix(stream): add expired epset node list for stream tasks in hb to mnode.	2023-10-27 23:41:57 +08:00
Haojun Liao	f682ad0479	refactor: do some internal refactor.	2023-10-27 09:55:06 +08:00
Haojun Liao	efede8669f	refactor: do some internal refactor.	2023-10-27 09:55:06 +08:00
Haojun Liao	579dd8e6b2	refactor(stream): do some internal refactor.	2023-10-27 09:54:56 +08:00
Haojun Liao	164159f293	enh(stream): add parameter to limit the stream sink task.	2023-10-27 09:54:07 +08:00
Haojun Liao	64bde93f85	fix(stream): not idle for sink task when no tokens are available.	2023-10-09 20:10:25 +08:00
Haojun Liao	9a7167aaba	fix(stream): sleep for 10ms	2023-10-09 20:10:24 +08:00
Haojun Liao	9af8ce21ed	fix(stream): wait for a while when no available token.	2023-10-09 20:10:23 +08:00
Haojun Liao	af2c0c95e9	refactor: do some internal refactor.	2023-10-09 20:10:22 +08:00
Haojun Liao	e95aea84ae	fix(stream): fix syntax error.	2023-10-09 20:10:21 +08:00