69 commits

Author	SHA1	Message	Date
lyh250-666	f91305c52f	enh:modify error code pass for taosMemoryCalloc in dnode/mgmt mnode/	2024-09-02 04:40:20 +00:00
dmchen	d6f13d838e	fix/TD-31542-fix-case	2024-08-28 10:52:03 +00:00
dmchen	f8c1e66960	fix/TD-31542-remove-assert-mnode	2024-08-28 05:33:43 +00:00
Haojun Liao	54fdea3173	fix(stream): perform node update when mnode leader/follower switches.	2024-08-15 18:01:28 +08:00
Haojun Liao	71b8f67ea6	refactor: do some internal refactor.	2024-08-09 11:37:34 +08:00
Haojun Liao	b24e8efa5f	Merge remote-tracking branch 'origin/fix/3_liaohj' into fix/3_liaohj	2024-08-09 02:02:56 +08:00
Haojun Liao	dfa74f82d7	fix(stream): avoid repeat send checkpoint-report msg.	2024-08-09 00:40:05 +08:00
Haojun Liao	fe7565330b	Merge branch '3.0' into fix/3_liaohj	2024-08-08 11:20:12 +08:00
Haojun Liao	3ae295dd1f	Merge pull request #27032 from taosdata/fix/syntax ... fix(stream):set accept code for trans.	2024-08-08 09:08:08 +08:00
Haojun Liao	255faa0eac	fix(stream): update acceptable code.	2024-08-07 11:43:38 +08:00
Haojun Liao	1e0b6b08b2	fix(stream):set accept code for trans.	2024-08-07 09:54:35 +08:00
dmchen	6a225d5639	fix/TD-31091-fix-case	2024-08-07 01:51:09 +00:00
dmchen	0a2d006c02	fix/TD-31091	2024-08-05 09:26:36 +00:00
Haojun Liao	c5bac71b32	fix(stream): remove invalid return code check.	2024-08-01 16:14:59 +08:00
Haojun Liao	3a1a528028	fix(stream): cancel fetch	2024-08-01 16:14:30 +08:00
Haojun Liao	400ed18c6a	fix(stream): fix memory leak.	2024-08-01 16:14:27 +08:00
Haojun Liao	e8f6454d17	fix(stream): compare vg replica according to different db.	2024-08-01 16:14:22 +08:00
Haojun Liao	90ab86deb6	fix(stream): remove invalid return code check.	2024-08-01 15:59:57 +08:00
Haojun Liao	6ba428fbf8	other: merge 3.0.	2024-08-01 11:15:49 +08:00
Haojun Liao	3a74d5bd11	fix(stream): cancel fetch	2024-08-01 09:21:54 +08:00
Haojun Liao	02123897b4	fix(stream): fix memory leak.	2024-07-31 19:55:26 +08:00
Haojun Liao	cf60900155	other: merge 3.0	2024-07-31 19:27:38 +08:00
Haojun Liao	4b9b1e2474	fix(stream): compare vg replica according to different db.	2024-07-31 19:24:41 +08:00
Haojun Liao	52b3e1be6f	fix(stream): drop orphan tasks/reset task in trans done by write-queue.	2024-07-31 14:08:22 +08:00
Haojun Liao	0bb263076e	fix(stream): check return value	2024-07-30 10:13:02 +08:00
Haojun Liao	ee03a7eea7	fix(stream): add some logs.	2024-07-24 13:29:15 +08:00
Haojun Liao	ad96333336	fix(stream): discard the processed hbmsg in the mnode.	2024-07-23 17:16:40 +08:00
Haojun Liao	7497f193c7	fix(stream): check return value, and do some internal refactor.	2024-07-23 14:47:29 +08:00
Haojun Liao	be162fb62f	fix(stream): check return value.	2024-07-22 13:31:57 +08:00
Haojun Liao	ebe1d09d74	fix(stream): check return value.	2024-07-22 10:07:18 +08:00
dmchen	e68ac2300e	fix/TD-30973	2024-07-17 03:22:02 +00:00
dapan1121	e527f2fd0b	fix: validate function return value	2024-07-12 15:22:39 +08:00
Haojun Liao	c71413c2aa	fix(stream): discard the repeat send consensus-checkpointId msg.	2024-07-09 14:52:15 +08:00
Haojun Liao	50a2ef08bd	fix(stream): update some logs.	2024-07-08 17:10:34 +08:00
Haojun Liao	56b7ec3d89	fix(stream): update some logs.	2024-07-08 15:10:00 +08:00
Haojun Liao	6e15c16cf7	fix(stream): check the set consensus-checkpointId ts.	2024-07-08 14:33:28 +08:00
Haojun Liao	647f9f47ef	refactor: do some internal refactor.	2024-07-08 10:32:23 +08:00
Haojun Liao	ce4153b6fc	fix(stream): use hb to send the consens-checkpointid req.	2024-07-08 09:05:33 +08:00
Haojun Liao	8e6bb176c2	fix(stream): use trans to set the consensus-checkpoint id	2024-07-05 16:17:20 +08:00
Haojun Liao	653f7a1a43	fix(stream): refactor the checkpoint consensus policy.	2024-07-04 13:55:50 +08:00
Haojun Liao	27cb3638c2	fix(stream): add more check before launching update stream task nodeEp	2024-07-03 09:20:37 +08:00
Haojun Liao	c73a003ee3	fix(stream): set the initial checkpointId for a new created stream.	2024-07-02 19:13:20 +08:00
Haojun Liao	c7d4f45b7f	fix(stream): remove invalid assert.	2024-07-02 15:33:25 +08:00
Haojun Liao	025437df0c	fix(stream): fix error in checkpoint consensus.	2024-06-27 19:25:18 +08:00
Haojun Liao	1818edcb2b	fix(stream): consensus the start checkpoint id, and extract the streamhb related functions into a new file.	2024-06-26 10:18:32 +08:00
Haojun Liao	d06e1549f1	fix(stream): add fill-history task id in msg.	2024-06-12 15:27:19 +08:00
Haojun Liao	dc2497791a	fix(stream): accept invalid vgroup id error code when handling the update checkpoint info.	2024-06-12 10:11:55 +08:00
Haojun Liao	3b537367c9	fix(stream): fix memory leak.	2024-06-11 15:21:48 +08:00
Haojun Liao	d6e252513e	fix(stream):fix syntax error.	2024-06-11 14:33:59 +08:00
Haojun Liao	0245d82e54	fix(stream): make sure that the unit test case can work.	2024-06-11 14:26:29 +08:00