7717 commits

Author	SHA1	Message	Date
Haojun Liao	b3d57e4a2d	fix(stream): not transfer state if state is not appropriate.	2023-11-02 19:31:35 +08:00
Haojun Liao	48aff868b6	fix(stream):update the log level.	2023-11-02 18:16:47 +08:00
Haojun Liao	3aed8c29ae	refactor: set different tq level.	2023-11-02 17:12:20 +08:00
Haojun Liao	351a31302f	fix(stream): add full unsupported event filtering.	2023-11-02 09:43:48 +08:00
Haojun Liao	246ed4e022	refactor: do some internal refactor.	2023-11-01 17:19:21 +08:00
Haojun Liao	12bc4f32cf	refactor: add some logs.	2023-11-01 16:12:15 +08:00
Haojun Liao	5ff89bc098	fix(stream): add lock log.	2023-11-01 13:19:53 +08:00
Haojun Liao	639d5cde47	fix(stream): add unsupport trans.	2023-10-31 23:14:02 +08:00
Haojun Liao	4c0242a58d	fix(stream): fix error in finishing event handling.	2023-10-31 16:39:14 +08:00
Haojun Liao	8b9bc988f1	fix(tsdb): fix syntax error.	2023-10-31 10:42:34 +08:00
Haojun Liao	eaf76854f6	fix(tsdb): handle the case where stt not exists, possibly exists while the stt-trigger is 1.	2023-10-31 09:29:24 +08:00
Haojun Liao	ed07486405	fix(tsdb): fix error in decide if data buffer overlaps with stt files/block-files.	2023-10-30 16:40:09 +08:00
Haojun Liao	bc1c2a879a	fix(tsdb): avoid to read duplicated rows in buf.	2023-10-30 16:12:08 +08:00
Haojun Liao	fdf3f210ac	refactor: do some internal refactor.	2023-10-30 14:39:24 +08:00
Haojun Liao	3275452bce	fix(stream): fix the deadlock.	2023-10-30 14:38:51 +08:00
Haojun Liao	93232a0e14	fix(stream): enable the set of fill-history task to be un-init.	2023-10-30 11:48:51 +08:00
Haojun Liao	4c267b538f	fix(stream): add expired epset node list for stream tasks in hb to mnode.	2023-10-27 23:05:41 +08:00
wade zhang	951442e3db	Merge pull request #23381 from taosdata/fix/TD-26884-main ... TD-26884	2023-10-26 16:59:39 +08:00
dmchen	7ef019d105	create table user and clusterid	2023-10-25 06:49:23 +00:00
Haojun Liao	f36b24ed24	fix(stream): disable follower nodes exec reset.	2023-10-25 14:16:36 +08:00
Haojun Liao	03165d5327	fix(stream): handle the repeatly issued nodeUpdate msg from dnode.	2023-10-25 09:55:02 +08:00
Haojun Liao	26aaa4a83c	other: merge main.	2023-10-25 00:39:14 +08:00
Haojun Liao	13d979a2ee	fix(stream): add some logs.	2023-10-25 00:03:46 +08:00
Haojun Liao	8cde39eebd	fix(stream): fix dead lock when shutdown all tasks.	2023-10-24 19:11:24 +08:00
Haojun Liao	f1498f8929	fix(stream): fix the invalid write in sma	2023-10-24 15:24:34 +08:00
dmchen	ae728ab412	create table	2023-10-24 06:17:13 +00:00
Haojun Liao	a6e706ba2d	fix(stream): ignore the check status when is ready.	2023-10-24 11:38:14 +08:00
Haojun Liao	e92b276e3e	fix(stream): set checkpoint failure when in pause status.	2023-10-24 10:14:29 +08:00
Haojun Liao	0dae8c3c76	refactor: do some internal refactor.	2023-10-24 09:49:14 +08:00
Haojun Liao	f446ff1c36	refactor(stream): do some internal refactor.	2023-10-24 09:48:10 +08:00
Haojun Liao	7a8b046a35	fix(sma): fix bugs in sma and do some internal refactor.	2023-10-24 09:40:38 +08:00
Haojun Liao	2ee3319611	Merge pull request #23360 from taosdata/fix/liaohj ... fix(tsdb): apply the window range when building blocks from stt files.	2023-10-23 12:45:42 +08:00
Haojun Liao	f1207d8d42	fix(tsdb): apply the window range when building blocks from stt files.	2023-10-20 18:18:58 +08:00
Haojun Liao	c4268ca395	fix(stream): fix bugs caused by refactor.	2023-10-20 15:54:30 +08:00
Haojun Liao	3b8c85f632	fix(stream): fix bugs caused by refactor sm.	2023-10-20 14:19:57 +08:00
Haojun Liao	270a847809	fix(stream): fix bugs caused by refactor sm.	2023-10-20 10:23:48 +08:00
Haojun Liao	d5059826a8	fix(stream): fix bugs caused by refactor.	2023-10-19 17:59:04 +08:00
Haojun Liao	c1cebae6ba	fix(stream): fix error in stream.	2023-10-19 16:20:27 +08:00
Haojun Liao	402aefd95d	refactor(stream): do some internal refactor.	2023-10-19 15:09:47 +08:00
Haojun Liao	f4caeca24a	refactor(stream): add state machine to manage the state of stream tasks.	2023-10-19 10:34:20 +08:00
Haojun Liao	54ec679b58	refactor(stream): do some internal refactor.	2023-10-18 15:34:53 +08:00
Haojun Liao	df07443379	Merge pull request #23288 from taosdata/fix/liaohj ... fix(stream):add more check for test cases.	2023-10-18 08:13:15 +08:00
yihaoDeng	b793c92fed	fix stream snap deadlock	2023-10-16 22:00:34 +08:00
yihaoDeng	f1186be19a	fix stream snap deadlock	2023-10-16 19:38:55 +08:00
yihaoDeng	0adefd5e59	fix stream snap deadlock	2023-10-16 19:26:33 +08:00
yihaoDeng	252b90bfab	fix stream snap deadlock	2023-10-16 19:20:09 +08:00
Haojun Liao	a1aa2c9e0c	fix(stream):add more check for test cases.	2023-10-16 18:47:01 +08:00
Haojun Liao	8f2c1944c0	fix(tdsb): adjust the log level.	2023-10-16 11:55:57 +08:00
Haojun Liao	ccecf05ff8	fix(tsdb): record the pinned block iter.	2023-10-16 11:48:57 +08:00
Haojun Liao	18bb27cdff	fix(stream): fix syntax error.	2023-10-16 10:16:39 +08:00