282 commits

Author	SHA1	Message	Date
Liu Jicong	82a1cc8e41	fix(wal): return correct msg for open wal file	2022-06-22 11:21:33 +08:00
Liu Jicong	f2b66cc16a	fix(stream): convert datablk to submit blk	2022-06-21 21:48:24 +08:00
Liu Jicong	3f6ce2da73	feat(tmq): support topic with meta	2022-06-21 15:18:09 +08:00
Liu Jicong	c409760f75	feat(stream): drop stream	2022-06-21 11:32:36 +08:00
Liu Jicong	450675f672	feat(stream): support snode	2022-06-20 20:18:34 +08:00
Liu Jicong	53ef66961a	feat(stream): support snode	2022-06-20 14:29:18 +08:00
Liu Jicong	d7660484cc	fix(tmq): performance issue	2022-06-17 15:10:00 +08:00
Liu Jicong	18993d50e5	refactor(tmq): offset storage	2022-06-17 13:16:46 +08:00
Liu Jicong	79494364ae	refactor(tmq): offset storage	2022-06-16 22:00:33 +08:00
Liu Jicong	5572abe1b4	feat(stream): drop task	2022-06-15 21:41:59 +08:00
Liu Jicong	60e007952c	Merge branch '3.0' into feature/stream	2022-06-15 17:06:35 +08:00
Liu Jicong	8eb08fa0d4	feat(stream): trigger mode add max delay	2022-06-15 16:11:20 +08:00
Cary Xu	cb7d0c2256	feat: tsma insert and query	2022-06-14 20:19:25 +08:00
Liu Jicong	04593fa44e	fix(stream): build table name	2022-06-14 16:38:33 +08:00
Liu Jicong	79d9c04a4c	fix: check error code	2022-06-14 15:22:50 +08:00
Liu Jicong	5881ef2690	refactor: convert datablock to submit block	2022-06-14 15:08:37 +08:00
Liu Jicong	601e454a24	enh(tmq): put offset store into vnode	2022-06-14 13:58:40 +08:00
Liu Jicong	0ef33c05bc	enh(tmq): avoid uninitialized memory	2022-06-11 21:36:15 +08:00
Cary Xu	25911e12a4	Merge branch '3.0' into feature/TD-14481-3.0	2022-06-11 15:16:20 +08:00
Cary Xu	ed829455a9	feat: tsma refactor	2022-06-11 15:15:55 +08:00
Liu Jicong	6f4f6c14fa	enh(tmq): add log	2022-06-11 14:02:48 +08:00
Liu Jicong	d3cf004164	fix(tmq): false cache	2022-06-10 18:04:03 +08:00
Cary Xu	988f4126b4	other: merge 3.0	2022-06-10 15:21:16 +08:00
Liu Jicong	73b8f02ac7	fix(stream): set child id	2022-06-10 12:00:38 +08:00
Cary Xu	69e7c77f4a	Merge branch '3.0' into feature/TD-14481-3.0	2022-06-09 15:15:22 +08:00
Cary Xu	ffe4d7cc62	other: merge 3.0	2022-06-09 11:55:11 +08:00
Liu Jicong	9e4b3adc7c	fix(stream): msg dispatch	2022-06-09 11:45:06 +08:00
Liu Jicong	b1226e5d06	feat(tmq): support err2str	2022-06-08 19:07:07 +08:00
Cary Xu	bac85eab63	Merge branch '3.0' into feature/TD-14481-3.0	2022-06-08 09:50:34 +08:00
Liu Jicong	6a5604fca6	Merge pull request #13582 from taosdata/feature/stream ... refactor(stream)	2022-06-07 22:05:17 +08:00
Liu Jicong	cbbf5f5d4d	refactor(stream)	2022-06-07 21:35:49 +08:00
Cary Xu	d4c33fba2f	feat: create tsma result stable	2022-06-07 20:49:27 +08:00
Hongze Cheng	e1967b5708	fix ci problem	2022-06-07 07:56:33 +00:00
Liu Jicong	858868d76a	refactor(stream): distributed execution	2022-06-07 10:54:18 +08:00
Liu Jicong	1b26da1bae	refactor(stream): distributed execution	2022-06-06 22:18:50 +08:00
Liu Jicong	2677a3c8d9	refactor(stream)	2022-06-06 20:15:36 +08:00
Liu Jicong	0ead238adb	feat(tmq): support check col and tag modifiable	2022-06-02 15:53:30 +08:00
Liu Jicong	f2048b00cb	fix(tmq): subscribe stb	2022-06-02 11:01:05 +08:00
Liu Jicong	e1fd4a6640	feat(tmq): get_db api	2022-06-02 10:18:11 +08:00
Liu Jicong	f3b680f630	refactor(tmq): push mode	2022-06-01 22:22:14 +08:00
Liu Jicong	135836c729	fix(tmq): tq deserialize msg	2022-06-01 19:57:03 +08:00
Liu Jicong	e1a5000e50	refactor(tmq): tq sink and push	2022-06-01 17:26:15 +08:00
Liu Jicong	98f62165ae	refactor(tmq): tq meta	2022-06-01 13:37:33 +08:00
Liu Jicong	66899bd8d0	fix(tmq): auto unsubscribe when consumer close	2022-06-01 10:27:41 +08:00
Liu Jicong	4169eb559a	fix(tmq): skip log	2022-05-31 17:02:43 +08:00
Liu Jicong	451d19f986	feat(tmq): create topic new grammar	2022-05-31 16:20:40 +08:00
Liu Jicong	2248bc4207	Merge branch '3.0' into feature/topic_grammar	2022-05-30 23:31:22 +08:00
Liu Jicong	1aa97bc117	fix(tmq): update tq for auto create table	2022-05-28 19:48:17 +08:00
Liu Jicong	05a0774b6d	feat(tmq): add sub type	2022-05-27 14:06:28 +08:00
Haojun Liao	d87bb5f3fa	refactor(query): set the block groupId for stream block.	2022-05-27 10:03:45 +08:00