298 commits

Author	SHA1	Message	Date
Haojun Liao	4b10393c81	fix(stream): fix memory leak and do some internal refactor.	2023-08-18 18:02:08 +08:00
Haojun Liao	e8c9a019a4	fix(stream): remove the invalid set of scheduler status.	2023-08-14 11:41:24 +08:00
Haojun Liao	0d38f389ab	refactor: do some internal refactor.	2023-08-13 16:25:35 +08:00
Haojun Liao	afe9b848a5	fix(tsdb): check the	2023-08-12 18:54:39 +08:00
Haojun Liao	09da6c6840	refactor: do some internal refactor.	2023-08-12 18:51:20 +08:00
Haojun Liao	75e6fb0f16	refactor: do some internal refactor.	2023-08-12 18:47:01 +08:00
Haojun Liao	8f9de93cf0	refactor: do some internal refactor.	2023-08-12 18:37:36 +08:00
Haojun Liao	ce721a0146	fix(stream): fix error.	2023-08-12 16:32:05 +08:00
Haojun Liao	a89ce1a20b	fix(stream): transfer state by using data block.	2023-08-12 01:24:07 +08:00
Haojun Liao	1e8579e8c5	fix(stream): fix other cases.	2023-08-09 16:04:48 +08:00
Haojun Liao	4c92997328	fix(stream): use streamId&taskId to identify the stream task in the stream meta.	2023-08-09 15:52:23 +08:00
yihaoDeng	6dc93a8dec	add stream ver	2023-08-04 13:52:20 +08:00
Haojun Liao	6365d5000b	Merge pull request #22271 from taosdata/fix/3_liaohj ... fix(stream): dump results to sink node before paused.	2023-08-01 15:50:17 +08:00
Haojun Liao	f6ae9cf9bb	fix(stream): fetch all data before paused and dump to sink node.	2023-08-01 10:16:14 +08:00
Haojun Liao	36ef9a537f	Merge pull request #22256 from taosdata/fix/TD-25457 ... check update data	2023-07-31 22:56:05 +08:00
Haojun Liao	d45596bb33	fix(stream): kill task when pause the stream execution.	2023-07-31 18:07:37 +08:00
liuyao	32b59af4b1	check update data	2023-07-31 17:32:24 +08:00
Haojun Liao	9981cecbed	refactor: do some internal refactor.	2023-07-31 15:24:35 +08:00
Haojun Liao	936afeb5ac	refactor: do internal refactor to simple the pause/resume in case of fill history exists.	2023-07-28 19:13:03 +08:00
Haojun Liao	d5974a8f25	refactor(stream): refactor the pause/resume for fill history execution.	2023-07-28 18:05:32 +08:00
Haojun Liao	22a5a18fff	fix(stream): 1. set correct timewindow after step2. 2. handle the case when the task is failed to be added into the meta store.	2023-07-27 18:57:36 +08:00
Haojun Liao	40fe3ef4f6	fix(stream): refactor the step2 wal scan.	2023-07-27 14:49:20 +08:00
Haojun Liao	e89f530db2	fix(stream): scan wal in step2	2023-07-27 10:55:59 +08:00
Haojun Liao	0bdccd2681	refactor: do some internal refactor.	2023-07-25 17:31:54 +08:00
Haojun Liao	a2694b9ce9	fix(stream): fix the invalid check of step2 .	2023-07-24 19:44:28 +08:00
Haojun Liao	1367552f38	fix(stream): refactor the halt status to check more status.	2023-07-24 10:04:15 +08:00
Haojun Liao	4e0f7ffbf8	fix(stream): set the correct flag of pause/resume.	2023-07-23 18:49:56 +08:00
Haojun Liao	1b2636028a	fix(stream): fix memory leak.	2023-07-21 23:05:42 +08:00
Haojun Liao	16d7707b90	fix(stream): align the scan real time data for stream task.	2023-07-21 19:33:43 +08:00
Haojun Liao	db46d31ca5	fix(stream): refactor the halt function.	2023-07-21 01:32:42 +08:00
Haojun Liao	aed99da6c1	refactor: refactor the stream task starting order.	2023-07-20 12:14:53 +08:00
Haojun Liao	97c44e7c18	refactor: do some internal refactor.	2023-07-19 18:42:02 +08:00
Haojun Liao	fed3803739	fix(stream): fix memory leak.	2023-07-11 19:29:52 +08:00
Haojun Liao	03dbcbf055	refactor: do some internal refactor.	2023-07-05 15:55:55 +08:00
Haojun Liao	57fcd553f8	refactor: do some internal refactor.	2023-06-28 13:13:13 +08:00
Haojun Liao	a19e63fd23	fix(stream): fix error in handling fill history.	2023-06-27 23:00:14 +08:00
Haojun Liao	b73444b291	fix(stream): start stream task in case of scan history completing.	2023-06-27 09:44:51 +08:00
Haojun Liao	402c091df0	fix(stream): fix sma error.	2023-06-25 19:41:44 +08:00
liuyao	41c193945f	fill history pause&resume	2023-06-19 17:28:19 +08:00
yihaoDeng	0eeaab9cd3	Merge branch 'refact/fillhistory1' into refact/fillhistory	2023-06-19 13:53:37 +08:00
Haojun Liao	64365666b7	fix(stream): update the info, and do some internal refactor.	2023-06-16 16:04:43 +08:00
yihaoDeng	9f9171719a	support fill history	2023-06-15 21:29:52 +08:00
liuyao	693942b821	trans state	2023-06-15 14:13:17 +08:00
Haojun Liao	53377c2c1f	fix(stream): wait for stream task completed.	2023-06-15 01:14:41 +08:00
liuyao	9a3708e17b	pause&resume fill history	2023-06-14 15:54:07 +08:00
Haojun Liao	7c6fbd7772	enh(stream): do some internal refactor and support secondary scan for history data.	2023-06-14 14:10:09 +08:00
Haojun Liao	11f0c3b336	refactor: do some internal refactor.	2023-06-14 10:46:46 +08:00
Haojun Liao	b44447e6f3	enh(stream): support restore from disk.	2023-06-14 10:19:03 +08:00
Haojun Liao	97da2a8fac	fix(stream): set the fill history status.	2023-06-13 16:10:55 +08:00
Haojun Liao	fb24ed161d	enh(stream): set correct task status.	2023-06-12 22:48:23 +08:00