98 commits

Author	SHA1	Message	Date
Liu Jicong	95f696b30d	enh(tmq): prevent drop db when topic exists	2022-08-10 17:24:47 +08:00
Liu Jicong	d9a4ea305d	fix(stream): memory error	2022-08-09 14:11:41 +08:00
Liu Jicong	43026ac31d	refactor(stream)	2022-08-08 11:29:50 +08:00
Liu Jicong	7c9d57bd89	refactor(stream): unify sink and dispatch	2022-08-05 20:16:47 +08:00
54liuyao	c1522632dc	fix(stream): amend error message	2022-08-04 13:39:16 +08:00
Liu Jicong	280ed4f65d	feat(stream): pipelined exec for recovering	2022-07-15 21:29:53 +08:00
Liu Jicong	9394e3380f	feat(stream): recover from failure	2022-07-15 17:58:53 +08:00
Liu Jicong	9ea0ad57ec	refactor(stream): destroy stream task	2022-07-14 15:32:21 +08:00
Liu Jicong	31bbef82d1	fix(tmq): seek snapshot offset	2022-07-02 20:18:40 +08:00
Shengliang Guan	f249bae82d	Merge remote-tracking branch 'origin/3.0' into fix/tsim	2022-07-02 14:14:01 +08:00
Shengliang Guan	0c510fcc8c	fix: drop db has stream exist	2022-07-02 11:55:59 +08:00
Liu Jicong	4a2b266612	feat(stream): support ignore expired flag	2022-07-02 10:59:29 +08:00
Liu Jicong	996f995644	fix(sma): drop stream when drop sma	2022-06-25 18:14:42 +08:00
Liu Jicong	bdd4134fc1	Revert "fix(sma): drop stream when drop sma"	2022-06-25 18:11:11 +08:00
Liu Jicong	3210fdc367	merge from 3.0	2022-06-25 17:49:25 +08:00
Liu Jicong	47ae534c0f	fix(sma): drop stream when drop sma	2022-06-25 17:44:54 +08:00
Shengliang Guan	1fb2c664a4	Merge pull request #14223 from taosdata/fix/tsim ... refactor: rename auth to privilege	2022-06-25 15:26:59 +08:00
Liu Jicong	e6f88b6286	Merge pull request #14225 from taosdata/feature/stream ... enh(query): window included in serialized retrieve table rsp	2022-06-25 11:35:18 +08:00
Shengliang Guan	23653fd843	enh: privilege for topic and stream	2022-06-25 11:22:34 +08:00
Liu Jicong	5040cb9541	enh(query): window included in serialized retrieve table rsp	2022-06-25 10:43:19 +08:00
Shengliang Guan	09ce47ae9f	refactor: rename auth to privilege	2022-06-25 10:27:27 +08:00
Liu Jicong	f53521cb8c	test(stream): partition by tbname	2022-06-24 16:50:11 +08:00
Liu Jicong	b884ca9db7	refactor(stream): seperate stream scheduling and persistence	2022-06-24 14:19:12 +08:00
Liu Jicong	c409760f75	feat(stream): drop stream	2022-06-21 11:32:36 +08:00
Liu Jicong	212144a3e6	test(stream): window close not work for stb	2022-06-20 21:50:13 +08:00
Shengliang Guan	5ae355077c	enh(mnode): transaction conflict supports two db	2022-06-17 11:11:29 +08:00
Shengliang Guan	80e0b830fe	refactor: remove duplicate conninfo in SRpcMsg	2022-06-17 10:40:42 +08:00
Liu Jicong	07288e26b2	refactor(stream): change msg name	2022-06-16 17:08:31 +08:00
Liu Jicong	44e733645c	ci: remove unstable case	2022-06-16 16:35:55 +08:00
Liu Jicong	32d8e60ce2	refactor(sma): create	2022-06-16 16:22:58 +08:00
Liu Jicong	928f45709d	feat(stream): drop stream	2022-06-16 16:01:22 +08:00
Liu Jicong	803249837a	feat(stream): drop stream	2022-06-16 10:29:30 +08:00
Liu Jicong	683bc24646	Merge pull request #13876 from taosdata/feature/stream ... feat(stream): drop task	2022-06-15 22:59:43 +08:00
Liu Jicong	5572abe1b4	feat(stream): drop task	2022-06-15 21:41:59 +08:00
Shengliang Guan	1b15c3439a	Merge pull request #13859 from taosdata/fix/dnode ... feat: increase enable and sysinfo limits for user privilege	2022-06-15 18:24:32 +08:00
Shengliang Guan	6711d79434	feat: increase enable and sysinfo limits for user privilege	2022-06-15 17:40:02 +08:00
Liu Jicong	d7a6c4976c	fix(stream): max delay should not be seen by operator (#13864)	2022-06-15 17:27:01 +08:00
Liu Jicong	d200fc710b	fix(stream): max delay should not be seen by operator	2022-06-15 17:25:47 +08:00
Liu Jicong	8eb08fa0d4	feat(stream): trigger mode add max delay	2022-06-15 16:11:20 +08:00
Xiaoyu Wang	380a071551	fix: handle the memory leak of parser	2022-06-13 14:54:38 +08:00
Liu Jicong	a7fba4b224	refactor(stream): stream scheduler	2022-06-10 21:57:59 +08:00
Liu Jicong	94d7cbe622	feat(stream): snode process stream msg	2022-06-07 16:24:50 +08:00
Shengliang Guan	980e289cdf	refactor: add alter-confirm while alter db	2022-06-05 14:59:53 +08:00
Shengliang Guan	1013b06107	refactor: make trans support global conflict	2022-05-31 19:24:26 +08:00
Shengliang Guan	9057abeb39	Merge remote-tracking branch 'origin/3.0' into fix/mnode	2022-05-31 17:39:57 +08:00
Shengliang Guan	04ef9e15e6	refactor: make trans support global conflict	2022-05-31 17:37:25 +08:00
Liu Jicong	d1259b3c82	fix(tmq): remove topic ref cnt	2022-05-30 22:50:59 +08:00
Liu Jicong	a0f3138888	fix(stream): tb name error	2022-05-26 11:16:35 +08:00
Shengliang Guan	a878b3edd5	fix: commit log should not be null	2022-05-23 21:17:04 +08:00
Shengliang Guan	682a7cab17	fix: avoid memory leak	2022-05-21 16:35:24 +08:00