10456 commits

Author	SHA1	Message	Date
Haojun Liao	2eeb13591c	Merge branch 'main' into fix/checkpoint	2025-03-10 10:15:23 +08:00
Haojun Liao	95e75196e2	chore: merge main.	2025-03-06 18:45:21 +08:00
Simon Guan	c642f5e6e0	Merge pull request #30033 from taosdata/fix/TS-6078-main ... fix(query): change error log to warning when failed to acquire tsdb reader	2025-03-06 17:19:03 +08:00
Jinqing Kuang	7a7aacd6cc	fix(query): change error log to warning when failed to acquire tsdb reader ... Jira: https://jira.taosdata.com:18080/browse/TS-6066	2025-03-06 14:23:00 +08:00
Haojun Liao	eb0553b737	refactor: do some internal refactor.	2025-03-04 18:45:29 +08:00
Haojun Liao	936f0af929	fix(analytics): check return value.	2025-03-04 17:04:07 +08:00
Haojun Liao	d2d7279f0d	fix(stream): fix memory leak if error occurs.	2025-03-01 19:22:26 +08:00
Haojun Liao	c726420081	Merge branch 'main' into fix/droptask	2025-02-28 19:42:35 +08:00
Haojun Liao	8c3035cf24	fix(stream): avoid lock in timer to avoid sync operation blocks.	2025-02-28 17:47:43 +08:00
Haojun Liao	e1c4451f81	fix(stream): avoid lock in timer to avoid sync operation blocks.	2025-02-28 17:46:54 +08:00
Haojun Liao	5f6ecab854	fix(stream): check the return values.	2025-02-28 15:05:00 +08:00
Haojun Liao	6e1206bbc1	fix(stream): add some logs.	2025-02-28 13:55:37 +08:00
Haojun Liao	951b469b10	fix(stream): add some logs.	2025-02-28 13:55:24 +08:00
Haojun Liao	14ef25101d	fix(stream): adjust log.	2025-02-28 13:55:09 +08:00
Haojun Liao	3e55f8edfe	fix(stream): follower nodes not restart tasks.	2025-02-28 13:54:26 +08:00
Haojun Liao	ed03b3a22c	fix(stream): try starting task even the inputQ is full.	2025-02-28 13:48:05 +08:00
Simon Guan	24fae6adbb	Merge pull request #29900 from taosdata/fix/checkfh ... refactor(stream): scan wal is driven by time, instead of insert events.	2025-02-28 13:42:43 +08:00
Haojun Liao	899d2cef20	fix(stream): not discard stream msg	2025-02-27 00:39:30 +08:00
Haojun Liao	786ee101cd	other: merge main.	2025-02-27 00:18:25 +08:00
Haojun Liao	bf1f162aa0	fix(stream): drop task in synch model in write thread.	2025-02-27 00:15:36 +08:00
Haojun Liao	012ee53d35	fix(stream): drop task in synch model in write thread.	2025-02-27 00:15:31 +08:00
Haojun Liao	45b0e47a19	refactor(stream): add long exec stream queue for history tasks in step1 and re-calculate task execution.	2025-02-27 00:15:03 +08:00
Haojun Liao	7319f544c2	refactor(stream): drop task in async ways	2025-02-27 00:14:34 +08:00
Haojun Liao	c14ba08d7c	refactor(stream): drop task in async ways	2025-02-27 00:12:11 +08:00
Haojun Liao	514a63ab37	fix(stream): fix the error in check scan interval	2025-02-24 00:40:16 +08:00
Haojun Liao	00edb8e612	fix(stream): adjust init tmr position.	2025-02-23 16:27:18 +08:00
Haojun Liao	787590b6c9	fix(stream): adjust init tmr position.	2025-02-23 16:25:17 +08:00
Haojun Liao	b4de2d16b6	fix(stream): add some logs.	2025-02-23 16:18:49 +08:00
Haojun Liao	f4c3fdedbd	fix(stream): add some logs.	2025-02-23 16:18:19 +08:00
Haojun Liao	4ff74ab2ea	fix(stream): adjust log.	2025-02-23 15:37:59 +08:00
Haojun Liao	8c0ead7c61	refactor: add some comments.	2025-02-23 11:03:49 +08:00
Haojun Liao	2fdb31a41a	fix(stream): adjust scan timer	2025-02-23 10:49:13 +08:00
Haojun Liao	f1c4d2734f	fix(stream): follower nodes not restart tasks.	2025-02-23 10:43:56 +08:00
Haojun Liao	e378b5cb8a	fix(stream): adjust scan timer	2025-02-23 03:42:44 +08:00
Haojun Liao	9018970135	refactor: do some internal refactor.	2025-02-23 01:39:00 +08:00
Haojun Liao	034c907ee1	refactor: do some internal refactor.	2025-02-23 01:38:05 +08:00
Haojun Liao	a8d50f28a6	fix(stream): disable error injection.	2025-02-22 14:19:44 +08:00
Haojun Liao	56f1c80018	fix(stream): disable error injection.	2025-02-22 14:18:44 +08:00
Haojun Liao	4d62c60aaf	fix(stream): fix syntax error.	2025-02-22 14:17:19 +08:00
Haojun Liao	6c92474afd	fix(stream): fix syntax error.	2025-02-22 14:16:46 +08:00
Haojun Liao	a9b5d0fbf0	fix(stream): update function return value.	2025-02-22 14:13:42 +08:00
Haojun Liao	9bd8b532ad	fix(stream): update function return value.	2025-02-22 14:12:38 +08:00
Haojun Liao	0ec8e1e202	refactor(stream): remove comments.	2025-02-22 12:38:19 +08:00
Haojun Liao	0f89421b62	refactor(stream): scan wal is driven by time, instead of insert events.	2025-02-22 12:38:03 +08:00
Haojun Liao	b5fdb44193	refactor(stream): remove comments.	2025-02-22 12:35:37 +08:00
Haojun Liao	09b6642e45	refactor(stream): scan wal is driven by time, instead of insert events.	2025-02-22 12:33:32 +08:00
Haojun Liao	2228a9fc33	Merge branch 'main' into fix/checkfh	2025-02-21 11:11:36 +08:00
Haojun Liao	ecc667c22b	Revert "refactor(stream): drop task in async ways"	2025-02-21 01:10:18 +08:00
Haojun Liao	9d5735703b	Merge branch 'fix/checkfh' into fix/checkpoint	2025-02-20 18:28:46 +08:00
Haojun Liao	bea8fe42db	fix(stream): check status before scan history.	2025-02-20 18:28:19 +08:00