12638 commits

Author	SHA1	Message	Date
wangmm0220	79c8a1494d	fix:disable snode unit test temporary	2023-12-05 11:26:12 +08:00
Haojun Liao	4d9211dcf1	Merge pull request #23899 from taosdata/fix/liaohj ... other: merge the patch of stream from 3.0 branch.	2023-12-01 15:49:54 +08:00
Haojun Liao	d7a19a9179	fix(stream): fix invalid decode hbmsg and memory leaks caused by invalid hb msg.	2023-12-01 14:45:18 +08:00
Haojun Liao	33ad05e2c8	fix(stream): fix syntax error.	2023-12-01 13:08:25 +08:00
Haojun Liao	12f32f0ae7	fix(stream): fix syntax error.	2023-12-01 11:57:16 +08:00
Haojun Liao	dba58f5e38	fix(stream): fix syntax error.	2023-12-01 11:54:13 +08:00
Haojun Liao	18273b8d1b	fix(stream): ignore the in_progress code.	2023-12-01 10:20:45 +08:00
Haojun Liao	2972f5f420	fix(stream):return the error code if create stream failed.	2023-12-01 10:20:45 +08:00
Haojun Liao	e008d0f440	fix(tsdb): fix invalid read.	2023-12-01 10:20:45 +08:00
Haojun Liao	fbb604d1f5	fix(tsdb): fix bugs in suspend/resume. adjust code to conduct the test more easily. td-27579	2023-12-01 10:20:44 +08:00
Haojun Liao	1c9ff8030b	fix(tsdb):clear the tsdb stt file reader flag when suspending the tsdbReader	2023-12-01 10:20:39 +08:00
Haojun Liao	86618ffd97	refactor: do some internal refactor.	2023-12-01 10:20:38 +08:00
Haojun Liao	31ae46925d	fix(stream): fix invalid free.	2023-12-01 10:20:32 +08:00
Haojun Liao	17d4a22e47	fix(stream): add logs.	2023-12-01 10:19:54 +08:00
Haojun Liao	b9c727575d	fix(stream): reset the scheduler status.	2023-12-01 10:19:54 +08:00
Haojun Liao	c937f42d88	fix(stream): fix deadlock.	2023-12-01 10:19:54 +08:00
Haojun Liao	8515a2f9b6	fix(stream): fix status check for stream-scan-history status when drop stream task msg is missing.	2023-12-01 10:19:18 +08:00
Haojun Liao	9d735e7f8b	fix(stream): reduce the sink throughput. and fix the bug in status check.	2023-12-01 10:18:25 +08:00
Haojun Liao	523573844a	fix(stream): fix syntax error.	2023-12-01 10:18:24 +08:00
Haojun Liao	eb2f5ad074	fix(stream): fix error.	2023-12-01 10:18:22 +08:00
Haojun Liao	2b03d64850	fix(stream): drop the related fill-history task & set the task to be ready, if the drop fill-history task msg is missing due to the vnode restarting.	2023-12-01 10:18:15 +08:00
Haojun Liao	60fa7cccbf	fix(stream): fix memory leak.	2023-12-01 10:17:14 +08:00
Haojun Liao	8b406c0a19	Merge pull request #23830 from taosdata/fix/liaohj ... fix(stream): fix invalid free.	2023-11-28 09:52:28 +08:00
Haojun Liao	b419650116	refactor: do some internal refactor.	2023-11-27 18:51:30 +08:00
Haojun Liao	91eea02258	fix(stream): fix invalid free.	2023-11-27 18:49:22 +08:00
Haojun Liao	d51baab9c2	Merge pull request #23785 from taosdata/fix/liaohj ... other: merge fix from 3.0 to main.	2023-11-24 14:43:02 +08:00
Haojun Liao	0654b9299a	fix(stream): fix memory leak.	2023-11-23 11:44:25 +08:00
Haojun Liao	8ad071e69a	other: merge main.	2023-11-23 10:25:51 +08:00
Haojun Liao	630b259d7f	fix(stream): fix error in stream.	2023-11-23 09:41:07 +08:00
Haojun Liao	ff9c0c0df4	fix(stream): fix error in check trans conflict.	2023-11-23 09:38:11 +08:00
Haojun Liao	f3355000a3	refactor: do some internal refactor.	2023-11-23 09:34:20 +08:00
Haojun Liao	6fca8c170c	enh(stream): add sink_quota/scan-history-idle-duration column for stream tasks.	2023-11-23 09:33:44 +08:00
Haojun Liao	8204db13aa	enh(stream): add sink_quota column for stream tasks.	2023-11-23 09:33:42 +08:00
Haojun Liao	3edb25a49e	fix(stream): add check for assert.	2023-11-23 09:33:40 +08:00
Haojun Liao	41aa175099	fix(stream): add return.	2023-11-23 09:33:36 +08:00
Haojun Liao	8c4558c5c2	Merge pull request #23763 from taosdata/fix/pause_stream ... fix(stream): fix error in generating token in bucket.	2023-11-21 15:46:25 +08:00
Haojun Liao	1077378d51	other: merge main.	2023-11-21 10:14:30 +08:00
Haojun Liao	4b3495cd4b	refactor: do some internal refactor.	2023-11-21 10:11:02 +08:00
dmchen	376f78788e	TD-27416	2023-11-20 08:43:12 +00:00
Haojun Liao	ec919415b8	enh(stream): add sink_quota/scan-history-idle-duration column for stream tasks.	2023-11-20 12:03:23 +08:00
Haojun Liao	56edf1b52c	enh(stream): add sink_quota column for stream tasks.	2023-11-20 12:03:23 +08:00
Haojun Liao	1b4f187ded	Merge pull request #23743 from taosdata/fix/pause_stream ... fix(stream): remove invalid assert	2023-11-17 23:48:47 +08:00
Haojun Liao	709502ba9e	fix(stream): record the check downstream failure.	2023-11-17 22:05:36 +08:00
Haojun Liao	0fac706fa6	Merge pull request #23732 from taosdata/fix/pause_stream ... fix(stream): add check for assert.	2023-11-17 11:33:19 +08:00
wade zhang	440a750d64	Merge pull request #23711 from taosdata/fix/TD-27336-main ... fix/TD-27336	2023-11-17 09:00:06 +08:00
Haojun Liao	c070e79d36	fix(stream): add check for assert.	2023-11-16 23:18:07 +08:00
dmchen	1e2c9b03a1	copy sql before destroy	2023-11-16 02:22:01 +00:00
dm chen	b18aa087da	Revert "create steam" ... This reverts commit cd6df48df5.	2023-11-16 10:09:46 +08:00
dmchen	cd6df48df5	create steam	2023-11-16 01:49:31 +00:00
dapan1121	dc71252096	Merge remote-tracking branch 'origin/3.0' into merge/32m	2023-11-15 19:43:19 +08:00