7421 commits

Author	SHA1	Message	Date
Haojun Liao	cd1f0ea414	Merge pull request #22826 from taosdata/fix/3_liaohj ... fix(stream): set the correct start version for the step 2 stage in fill history.	2023-09-11 21:43:58 +08:00
Haojun Liao	5ab739ae46	fix(stream): fix memory leak.	2023-09-11 15:29:12 +08:00
Haojun Liao	c729fc989f	fix(stream): set the init start timestamp.	2023-09-11 13:49:43 +08:00
Haojun Liao	0980e021e5	fix(stream): set the correct start version for the step 2 stage in fill history.	2023-09-11 13:37:19 +08:00
Haojun Liao	50ef500f51	refactor(stream): do sink module refactor.	2023-09-11 10:09:31 +08:00
Haojun Liao	372747cc23	Merge pull request #22818 from taosdata/fix/3_liaohj ... fix(stream): fix error in fill history and check quit status of vnode.	2023-09-10 20:47:06 +08:00
Haojun Liao	85a5c45098	fix(stream): limit the already processed data.	2023-09-10 00:01:25 +08:00
Haojun Liao	9a30573b8b	fix(stream): disable scan wal when halt is set.	2023-09-09 16:12:08 +08:00
Haojun Liao	aa8909b267	other: add some logs.	2023-09-09 15:18:54 +08:00
Haojun Liao	6f5c855a4b	fix(stream): fix msg lost bug.	2023-09-09 15:08:36 +08:00
Haojun Liao	47fd144447	other: add some logs.	2023-09-09 11:19:51 +08:00
Haojun Liao	b317c8ebff	fix(stream): disable merge submit blocks.	2023-09-08 12:46:15 +08:00
Benguang Zhao	2d5b18039d	fix: next merger iter of tombs in loop of tsdbSnapWriteTombRecord	2023-09-07 17:14:50 +08:00
wade zhang	d3f0c5ac3e	Merge pull request #22770 from taosdata/fix/TD-25445-main ... fix/TD-25445: search memory in ttlMgrFindExpired	2023-09-07 16:13:32 +08:00
Haojun Liao	55ac835294	Merge branch 'main' into fix/3_liaohj	2023-09-07 11:47:25 +08:00
Haojun Liao	b240e91c91	enh(stream): add token bucket to limit the rate of sink operation.	2023-09-07 09:58:48 +08:00
Shungang Li	a6ba7e678f	fix: search memory in ttlMgrFindExpired	2023-09-07 09:33:26 +08:00
Haojun Liao	2b84e0b02e	refactor: check if the put data into queue is success or failed.	2023-09-06 19:39:00 +08:00
Haojun Liao	8edf86b3bb	fix(stream): add some logs.	2023-09-06 19:08:09 +08:00
Haojun Liao	5ba6a68e7a	fix(stream): fix syntax error.	2023-09-06 19:00:39 +08:00
Haojun Liao	a82027f492	enh(stream): pack multi-datablock into one submit message.	2023-09-06 18:58:47 +08:00
wade zhang	e493f983ed	Merge pull request #22735 from taosdata/fix/TD-26133 ... fix: coverity scan	2023-09-06 18:45:23 +08:00
Haojun Liao	f8a321695a	Merge pull request #22711 from taosdata/fix/TD-26069-1 ... fix rc	2023-09-06 17:58:33 +08:00
Hongze Cheng	1d343fa57e	more fix	2023-09-06 17:10:36 +08:00
Haojun Liao	926cc01cff	refactor: do some internal refactor.	2023-09-06 16:48:43 +08:00
Hongze Cheng	cd88c8ec31	fix: little test	2023-09-06 14:45:53 +08:00
Haojun Liao	b382cba58c	fix(stream): fix syntax error.	2023-09-06 14:37:58 +08:00
Haojun Liao	236b363996	fix(stream): fix syntax error.	2023-09-06 14:37:11 +08:00
Haojun Liao	8783ebcb02	enh(stream): add some logs and record the submit package performance.	2023-09-06 14:34:36 +08:00
Hongze Cheng	a6743a31b5	Merge branch 'main' of https://github.com/taosdata/TDengine into fix/TD-26133	2023-09-06 14:12:21 +08:00
Haojun Liao	e607a0a5cb	fix(stream): add some logs.	2023-09-06 11:39:07 +08:00
Haojun Liao	c86eeb3938	fix(stream): add task status check when waiting for the table create.	2023-09-06 10:58:33 +08:00
Haojun Liao	ac8f4f1558	Merge pull request #22736 from taosdata/fix/fixTransferCrash ... fix invalid read	2023-09-05 15:42:03 +08:00
yihaoDeng	d0503a8a3f	fix invalid read	2023-09-05 12:11:58 +08:00
Hongze Cheng	8dbdeccc8f	fix: coverity scan	2023-09-05 11:41:36 +08:00
wade zhang	8f27724f1f	Merge pull request #22701 from taosdata/fix/test_1x ... test: add stream cases to main	2023-09-05 10:57:38 +08:00
Haojun Liao	0441c7a870	Merge branch 'fix/3_liaohj' of github.com:taosdata/tdengine into fix/3_liaohj	2023-09-05 10:40:48 +08:00
Haojun Liao	5b3cb8ec42	fix(stream): fix memory leak.	2023-09-05 09:27:16 +08:00
Haojun Liao	db8073dadd	fix(stream): fix memory leak.	2023-09-04 23:13:57 +08:00
Haojun Liao	77eed06bcd	Merge branch '3.0' into fix/3_liaohj	2023-09-04 18:51:07 +08:00
Haojun Liao	aeea699c9c	Merge branch '3.0' into fix/3_liaohj	2023-09-04 15:53:39 +08:00
Haojun Liao	ed22dd5f26	fix(stream): fix deadlock caused during merging branch.	2023-09-04 14:09:39 +08:00
Haojun Liao	375d0abea5	fix(stream): merge main.	2023-09-04 13:12:53 +08:00
Haojun Liao	21dab8ceab	other: merge 3.0	2023-09-04 13:08:19 +08:00
yihaoDeng	03cddfa7ce	fix rc	2023-09-04 10:33:01 +08:00
Haojun Liao	4fee5ba59a	fix(stream): even in ck, start stream tasks.	2023-09-01 14:40:30 +08:00
dapan1121	cc17848b78	fix: merge 3.0 to main	2023-09-01 13:24:47 +08:00
dapan1121	2141ac8460	Merge remote-tracking branch 'origin/main' into fix/m23.2	2023-09-01 11:21:38 +08:00
Hongze Cheng	113867081e	enh: upgrade more efficiently	2023-09-01 10:16:10 +08:00
dapan1121	228e6c6acd	Merge remote-tracking branch 'origin/main' into 3.0	2023-09-01 10:01:10 +08:00