105 commits

Author	SHA1	Message	Date
Cary Xu	1231c8014b	fix: solve rsma memory leak	2022-08-04 21:27:01 +08:00
Shengliang Guan	56f2e49764	refactor: adjust logs	2022-08-02 17:12:07 +08:00
Liu Jicong	c67f5f10a2	Merge pull request #15595 from taosdata/feature/stream ... enh(wal): add lock to guarantee read behaviour	2022-07-30 17:09:20 +08:00
Liu Jicong	f24f2eff42	merge 3.0	2022-07-30 13:03:12 +08:00
Haojun Liao	ed57347579	fix(query): fix memory leak.	2022-07-30 11:30:31 +08:00
Liu Jicong	6c250e75cd	fix(stream): forbid histogram in stream	2022-07-29 21:28:18 +08:00
Haojun Liao	9ee13ca254	other: merge 3.0	2022-07-29 18:03:42 +08:00
Haojun Liao	26e5a7c796	refactor: do some internal refactor.	2022-07-29 13:54:14 +08:00
Cary Xu	e3efc089b4	fix: assign groupId for rsma uniformly	2022-07-29 12:15:19 +08:00
Cary Xu	21fba3cb1f	other: revert the walWrite.c	2022-07-28 17:15:31 +08:00
Cary Xu	0dcb3a5da1	fix: assign uid for rsma by physical plan	2022-07-28 17:07:47 +08:00
Liu Jicong	ba0c1b3689	refactor(stream)	2022-07-27 20:11:03 +08:00
Liu Jicong	5e1bbe0e7e	refactor(sma): remove option	2022-07-27 16:55:23 +08:00
Liu Jicong	3167f158d1	Merge pull request #15454 from taosdata/feature/stream ... fix(stream): dispatch	2022-07-27 12:39:37 +08:00
Liu Jicong	3fa5791889	fix(stream): dispatch	2022-07-27 10:52:25 +08:00
wangmm0220	915d3c4203	fix:conflicts from 3.0	2022-07-26 17:47:10 +08:00
wangmm0220	ba1962cacf	feat:add tmq get data interface	2022-07-26 17:43:22 +08:00
Haojun Liao	90b3e77698	fix(query):disable merge for project operator in stream processing.	2022-07-25 16:02:49 +08:00
Haojun Liao	e9936db95e	other: merge 3.0	2022-07-23 09:37:23 +08:00
Haojun Liao	998dedb9fa	other: merge 3.0	2022-07-22 21:16:52 +08:00
Haojun Liao	6f4851a6a2	refactor: do some internal refactor.	2022-07-22 14:38:28 +08:00
Liu Jicong	c82bda25e2	refactor(tmq): add debug log	2022-07-21 21:48:05 +08:00
Haojun Liao	9d565752c4	fix(query): extract schema before creating stream scanner.	2022-07-21 13:51:39 +08:00
Haojun Liao	c2d588a118	other:merge 3.0	2022-07-21 11:29:34 +08:00
Haojun Liao	ee34c3bb3e	fix(query): add query involved column info	2022-07-21 11:20:30 +08:00
Haojun Liao	dae00fd10c	Merge pull request #15221 from taosdata/feature/3_liaohj ... refactor(query): do some internal refactor and add some logs.	2022-07-21 11:14:56 +08:00
Haojun Liao	abfa6d9162	refactor(query): do some internal refactor and add some logs.	2022-07-20 22:38:19 +08:00
Liu Jicong	edaec52bca	refactor: add debug flag	2022-07-19 19:59:07 +08:00
Liu Jicong	414673db57	Merge branch '3.0' into feature/stream	2022-07-19 19:46:36 +08:00
Liu Jicong	24bc71568e	refactor(stream): batch optimization for submit msg	2022-07-19 18:29:12 +08:00
Haojun Liao	179709f814	fix(query): assign the subplan to belong to task struct	2022-07-19 17:37:40 +08:00
Haojun Liao	79b0240a87	fix(query): fix some memory leak.	2022-07-19 16:34:26 +08:00
Haojun Liao	cd2eaf0152	fix(query): set the output column number for subscribe.	2022-07-19 16:01:28 +08:00
Liu Jicong	bc1af6deaf	refactor(stream): batch optimization for submit msg	2022-07-19 15:52:08 +08:00
Haojun Liao	eebbbce4f3	fix(query): filter new added child table for stream scan operator.	2022-07-18 15:31:39 +08:00
Liu Jicong	8a6e4b877a	refactor(stream): simple batch	2022-07-13 16:37:33 +08:00
Liu Jicong	d637ffe22c	refactor(tmq): prepare only needed	2022-07-12 14:10:22 +08:00
Liu Jicong	f9ba552496	Merge pull request #14739 from taosdata/feature/stream ... fix(wal): read after rolling	2022-07-10 21:45:31 +08:00
Liu Jicong	219d966b25	fix(wal): read after rolling	2022-07-10 21:02:25 +08:00
Haojun Liao	7dc7f478de	refactor: do some internal refactor and fix some memory leak.	2022-07-10 17:34:21 +08:00
Liu Jicong	3cd5a35054	refactor(stream): internal refactor	2022-07-08 17:48:34 +08:00
Liu Jicong	866e4c4be0	refactor(stream): internal refactor	2022-07-07 17:56:52 +08:00
Liu Jicong	db23b07ae1	merge from 3.0	2022-07-06 21:12:46 +08:00
Liu Jicong	8c5dbde918	refactor(stream): stream reader created in scanner	2022-07-06 14:20:07 +08:00
Hongze Cheng	ddb198de23	Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/tsdb_refact	2022-07-04 03:42:50 +00:00
Liu Jicong	4a2b266612	feat(stream): support ignore expired flag	2022-07-02 10:59:29 +08:00
Liu Jicong	c2955a807b	feat(tmq): offset support snapshot	2022-06-29 21:04:51 +08:00
Haojun Liao	f2b83dfb4a	fix(query):check null ptr.	2022-06-29 10:35:07 +08:00
Haojun Liao	5efd5a3b6d	fix(query):adjust api for retrieve lastrow in executor.	2022-06-28 23:24:20 +08:00
Liu Jicong	bdd4134fc1	Revert "fix(sma): drop stream when drop sma"	2022-06-25 18:11:11 +08:00