1636 commits

Author	SHA1	Message	Date
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	dcca6b0868	other: merge 3.0.	2023-10-27 11:41:28 +08:00
Haojun Liao	454624516c	fix(stream): handle the repeatly issued nodeUpdate msg from dnode.	2023-10-27 09:59:51 +08:00
Haojun Liao	33dc51cc86	fix(stream): add some logs.	2023-10-27 09:59:44 +08:00
Haojun Liao	1ccbb77981	fix(stream): fix dead lock when shutdown all tasks.	2023-10-27 09:59:37 +08:00
Haojun Liao	2493c21ed3	fix(stream): fix the invalid write in sma	2023-10-27 09:58:52 +08:00
Haojun Liao	7cce53f7e5	fix(stream): ignore the check status when is ready.	2023-10-27 09:58:52 +08:00
Haojun Liao	c99f434706	fix(stream): set checkpoint failure when in pause status.	2023-10-27 09:58:52 +08:00
Haojun Liao	1ad2c3029a	refactor(stream): do some internal refactor.	2023-10-27 09:58:52 +08:00
Haojun Liao	7311f9d2fe	fix(sma): fix bugs in sma and do some internal refactor.	2023-10-27 09:58:51 +08:00
Haojun Liao	3bcffcf1da	other: merge stream refactor from main.	2023-10-27 09:56:02 +08:00
Haojun Liao	226b6596d6	fix(stream): fix bugs caused by refactor.	2023-10-27 09:54:58 +08:00
Haojun Liao	091238e7be	fix(stream): fix bugs caused by refactor sm.	2023-10-27 09:54:58 +08:00
Haojun Liao	e1f6043eed	fix(stream): fix bugs caused by refactor sm.	2023-10-27 09:54:57 +08:00
Haojun Liao	8729bdac1e	fix(stream): fix bugs caused by refactor.	2023-10-27 09:54:57 +08:00
Haojun Liao	1eac7f44c0	fix(stream): fix error in stream.	2023-10-27 09:54:56 +08:00
Haojun Liao	579dd8e6b2	refactor(stream): do some internal refactor.	2023-10-27 09:54:56 +08:00
Haojun Liao	6f3c0d17cc	refactor(stream): add state machine to manage the state of stream tasks.	2023-10-27 09:54:49 +08:00
Haojun Liao	596eb073b7	refactor(stream): do some internal refactor.	2023-10-27 09:54:48 +08:00
Haojun Liao	62c58ecd8b	fix(stream):add more check for test cases.	2023-10-27 09:54:06 +08:00
Benguang Zhao	c4e9069a66	fix: set nextProcessedVer properly in tqProcessTaskScanHistory	2023-10-19 11:18:57 +08:00
Haojun Liao	c6dd73b68b	Merge pull request #23187 from taosdata/feat/TD-26056 ... feat:add replay logic	2023-10-18 11:43:43 +08:00
yihaoDeng	b133418d88	fix stream snap deadlock	2023-10-16 20:03:44 +08:00
yihaoDeng	f5ea3649c5	fix stream snap deadlock	2023-10-16 19:26:08 +08:00
yihaoDeng	0a84d7a8b3	fix stream snap deadlock	2023-10-16 19:20:48 +08:00
wangmm0220	473142fab7	fix:conflicts from 3.0	2023-10-16 11:35:56 +08:00
Alex Duan	35fced8796	Merge pull request #23234 from taosdata/main_3_merge ... other: merge main into 3.0	2023-10-12 07:48:20 -05:00
Haojun Liao	b782af2534	fix(stream): avoid double free.	2023-10-12 17:56:42 +08:00
Haojun Liao	eb4449999f	other: merge 3.0	2023-10-12 10:33:48 +08:00
wangmm0220	f7d1e0ea82	fix:[TD-26671] judge if pointer is null to avoid core dump	2023-10-11 11:08:14 +08:00
wangmm0220	440fa77282	fix:merge datablock if data in same wal version	2023-10-10 16:55:36 +08:00
Haojun Liao	5f9b858fc1	other: merge main.	2023-10-10 15:38:46 +08:00
Haojun Liao	adf6f65d09	fix(stream): set initial version for fill-history task. disable reentry of scan-history task function.	2023-10-10 14:00:30 +08:00
Alex Duan	9da96ebf63	Merge pull request #23017 from taosdata/case/TD-26408-MAIN ... fix: add case for lost data after split vgroup (main)	2023-10-10 00:54:34 -05:00
wangmm0220	9113c3c3b6	fix:rollback removed code	2023-10-10 11:53:54 +08:00
wangmm0220	3e2e924e98	feat:[TD-26056] add replay logic	2023-10-09 18:36:39 +08:00
wangmm0220	33045e63ae	feat:[TD-26056] add replay logic	2023-10-09 17:35:40 +08:00
Haojun Liao	8266c4ff77	fix(stream): remove invalid clear of rspmsg list.	2023-10-09 15:26:42 +08:00
Haojun Liao	74ff0c5b50	Merge branch 'main' into fix/liaohj	2023-10-09 10:14:53 +08:00
Haojun Liao	ee6516f3c4	enh(stream): add trans to reset task status to avoid being frozen in checkpoint status due to doing checkpoint failure of partial tasks.	2023-10-09 10:13:53 +08:00
Haojun Liao	0fda1793e7	fix(stream): fix error in fill-history process.	2023-10-09 10:08:48 +08:00
wangmm0220	3f2d890560	feat:[TD-26056] add replay logic	2023-10-08 16:06:15 +08:00
wangmm0220	fb3197ea89	fix:test case error for reset=latest	2023-10-08 10:55:35 +08:00
Haojun Liao	ab17bfdf09	refactor: do some internal refactor.	2023-10-07 19:16:55 +08:00
yihaoDeng	97fdcbc60b	fix mem leak	2023-10-07 17:48:24 +08:00
wangmm0220	9c470e9297	opti:set default offset to latest in subscription & return error if use snapshot when consume column	2023-10-07 15:25:24 +08:00
Haojun Liao	7ce3d2c200	fix(stream): quit from loop when input queue is full.	2023-10-07 14:54:11 +08:00
Haojun Liao	c20dd002fb	enh(stream): add more info for sink task.	2023-10-07 01:14:00 +08:00
Haojun Liao	5bf8d16ee1	refactor(stream): idle for 100ms when starting next round scan wal.	2023-10-04 23:33:03 +08:00
Haojun Liao	41ef1a45c1	enh(stream): optimize the scan wal perf	2023-10-04 22:06:46 +08:00