106 commits

Author	SHA1	Message	Date
Haojun Liao	69f95f9324	other: merge 3.0	2023-08-31 13:56:34 +08:00
Haojun Liao	3fc3dafca6	refactor: do some internal refactor.	2023-08-31 13:46:48 +08:00
yihaoDeng	83a5e2be4c	stream change ver	2023-08-31 11:42:12 +08:00
yihaoDeng	05ca71d5de	stream change ver	2023-08-31 09:28:43 +08:00
Haojun Liao	391103bc5a	fix(stream): do dome internal refactor.	2023-08-28 15:54:01 +08:00
Haojun Liao	60d1df0e25	Merge branch '3.0' into enh/triggerCheckPoint2	2023-08-25 15:49:28 +08:00
Haojun Liao	f7dada53b9	Merge pull request #22559 from taosdata/fix/liaohj ... other: merge main.	2023-08-24 19:01:18 +08:00
Haojun Liao	8e07703dd2	fix(stream): reset the timerActive value.	2023-08-23 18:26:07 +08:00
Haojun Liao	230d8c2d80	fix(stream): fix error in stream computing after vnode is transferred to other dnodes.	2023-08-23 17:50:44 +08:00
yihaoDeng	ab9490101f	Merge branch 'enh/3.0' into enh/triggerCheckPoint2	2023-08-22 18:04:04 +08:00
Haojun Liao	af80d94a88	refactor: do some internal refactor.	2023-08-22 15:43:50 +08:00
Haojun Liao	cc8b2263cb	fix(stream): fix error in heartbeat from vnode.	2023-08-22 13:37:38 +08:00
Haojun Liao	8b27f98ee4	refactor: do some internal refactor.	2023-08-21 19:08:27 +08:00
Haojun Liao	29bb5854cc	fix(stream): fix error in check stream state.	2023-08-21 11:48:55 +08:00
yihaoDeng	8e4411c144	fix checkpoint error	2023-08-18 21:42:35 +08:00
Haojun Liao	4b10393c81	fix(stream): fix memory leak and do some internal refactor.	2023-08-18 18:02:08 +08:00
Haojun Liao	a8b53c2e69	other: add logs.	2023-08-18 10:51:59 +08:00
Haojun Liao	87785b1d9c	refactor: add some logs.	2023-08-18 10:30:00 +08:00
Haojun Liao	d63758a1c5	fix(stream): fix error in execute task on a tranferred node.	2023-08-16 15:24:24 +08:00
Haojun Liao	6d7b6fbb74	other: add some logs.	2023-08-15 20:01:53 +08:00
Haojun Liao	fe5e48b87d	fix(stream): remove redundant include.	2023-08-15 09:26:35 +08:00
Haojun Liao	b1d35f43ba	enh(stream): using term from sync module to denote the upstream node is restarted/replica-modified/vnode-transferred or not.	2023-08-15 09:25:05 +08:00
Haojun Liao	87c7e4c0fe	fix(stream): not launch stream tasks when restarting the stream tasks.	2023-08-11 16:19:46 +08:00
Haojun Liao	e984affe90	fix(stream): disable the stream in the followers nodes.	2023-08-11 15:58:15 +08:00
Haojun Liao	4afe603c6e	fix(stream): fix error.	2023-08-11 14:17:09 +08:00
Haojun Liao	6a9826cf6e	enh(stream): update the stream task epset.	2023-08-11 10:37:25 +08:00
Haojun Liao	f633c7fe2b	other: merge 3.0.	2023-08-10 11:56:30 +08:00
Haojun Liao	c10b323188	other: merge main.	2023-08-10 09:26:33 +08:00
Haojun Liao	3cdb16352c	fix(stream): avoid launching check downstream when failed to add stream task into stream meta.	2023-08-09 12:03:14 +08:00
Haojun Liao	af3a87560a	refactor: do some refactor.	2023-08-08 09:11:41 +08:00
Haojun Liao	f8ee055641	other: merge 3.0	2023-08-08 00:19:08 +08:00
Haojun Liao	aea1690cd1	fix(stream): fix the stream task after checking if it is in the timer activities.	2023-08-07 17:49:36 +08:00
Haojun Liao	225c0e61dc	hen(stream): support the rollback and checkdown stream tasks.	2023-08-07 16:13:39 +08:00
yihaoDeng	6dc93a8dec	add stream ver	2023-08-04 13:52:20 +08:00
Haojun Liao	e61aa83594	enh(stream): handle the stream hb.	2023-07-31 14:07:18 +08:00
Haojun Liao	8dfef8768a	other: merge 3.0	2023-07-29 22:54:16 +08:00
Haojun Liao	cdffabcdad	fix(stream): fix memory leak.	2023-07-26 14:37:04 +08:00
Haojun Liao	728112ed89	fix(stream): set correct upstream epinfo.	2023-07-26 10:26:59 +08:00
Haojun Liao	c116b69941	fix(stream): fix memory leak.	2023-07-25 09:25:18 +08:00
Haojun Liao	1e34f84f78	other: merge 3.0	2023-07-24 15:23:03 +08:00
Haojun Liao	f4864b8713	fix(stream): fix memory leak.	2023-07-22 01:02:58 +08:00
Haojun Liao	1b2636028a	fix(stream): fix memory leak.	2023-07-21 23:05:42 +08:00
Haojun Liao	97c44e7c18	refactor: do some internal refactor.	2023-07-19 18:42:02 +08:00
Haojun Liao	d2c875e774	Merge remote-tracking branch 'origin/enh/triggerCheckPoint2' into enh/triggerCheckPoint2	2023-07-18 15:19:09 +08:00
Haojun Liao	901b7d8ecc	fix(stream): if a source task is set to be non-normal, no data should be put into inputQ anymore.	2023-07-18 15:18:57 +08:00
yihaoDeng	40d59990d8	fix mem leak	2023-07-18 04:01:20 +00:00
Haojun Liao	2f24f776fb	fix(stream): fix error in generating checkpoint for state_window.	2023-07-18 09:04:28 +08:00
Haojun Liao	b2a905bd91	Merge branch '3.0' into enh/triggerCheckPoint2	2023-07-17 11:50:12 +08:00
Haojun Liao	eb7e6152ae	refactor(stream): do some internal refactor.	2023-07-14 17:21:20 +08:00
Haojun Liao	813f4cb363	refactor: do some internal refactor.	2023-07-13 16:32:25 +08:00