261 commits

Author	SHA1	Message	Date
Haojun Liao	fce5be0eb4	fix(stream): fix dead lock.	2023-09-14 14:09:05 +08:00
Haojun Liao	e8294ed8dc	fix(stream): fix bug in multi-replica vnode redistribute.	2023-09-01 03:10:12 +08:00
Haojun Liao	e53b5d4392	refactor: do some internal refactor.	2023-08-31 11:01:53 +08:00
Haojun Liao	d99d8875e1	fix(stream): if stream task is running, do not recheck its status.	2023-08-30 17:24:13 +08:00
yihaoDeng	9310d138a6	Merge branch 'enh/3.0' into enh/triggerCheckPoint2	2023-08-24 17:30:35 +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	39079ab64a	fix(stream): load term from sync model to decide if the node is restart or not	2023-08-15 15:52:06 +08:00
dmchen	7d480cf3ac	compatible old sync config	2023-07-21 10:31:53 +08:00
dmchen	3711fdd865	feat/TD-22970	2023-07-18 16:09:38 +08:00
Haojun Liao	f4a3567935	other: merge 3.0	2023-07-06 11:24:30 +08:00
yihaoDeng	6b6e237079	add checkpoint	2023-06-28 09:57:08 +00:00
Haojun Liao	64365666b7	fix(stream): update the info, and do some internal refactor.	2023-06-16 16:04:43 +08:00
Haojun Liao	74e0138f72	Merge branch '3.0' into refact/fillhistory	2023-06-15 15:25:00 +08:00
Haojun Liao	b44447e6f3	enh(stream): support restore from disk.	2023-06-14 10:19:03 +08:00
Benguang Zhao	28efd7dcd7	enh: check trans conflicts in mndTransValidate	2023-05-31 10:53:36 +08:00
Haojun Liao	de44c9160c	refactor: do some internal refactor.	2023-05-20 18:05:39 +08:00
Haojun Liao	7ef16e1922	other: merge main.	2023-05-12 11:49:53 +08:00
Haojun Liao	05d416f3b9	fix(stream): fix invalid access when handling error, not start stream if tsDisablestream is set.	2023-04-28 23:53:53 +08:00
Haojun Liao	057cc2d30d	Merge pull request #21018 from taosdata/feature/3_liaohj ... fix(stream): set the correct start offset for stream task.	2023-04-24 12:02:20 +08:00
dm chen	d594e4963f	Merge branch '3.0' into feat/learner	2023-04-20 19:11:06 +08:00
Benguang Zhao	a21e0fe75e	enh: propose vnode commit synchronously	2023-04-20 14:28:56 +08:00
cadem	3b78d4382b	add learner	2023-04-18 19:03:45 +08:00
Haojun Liao	1350af5267	fix(stream): set the correct initial checkpoint version to restore the operators state and add check for the initial destination tables.	2023-04-16 22:48:22 +08:00
Haojun Liao	1cd2268a99	Merge branch 'main' into feature/3_liaohj	2023-04-14 18:30:55 +08:00
Haojun Liao	70b45a4cf0	fix(stream): all data should be extracted from wal.	2023-04-13 23:22:09 +08:00
Benguang Zhao	d8386754ee	enh: try to propose vnode commit at vnode closing	2023-04-13 19:45:24 +08:00
Haojun Liao	7419c0bfe9	enh(stream): the stream will start after vnode restore being completed.	2023-04-10 16:56:14 +08:00
Benguang Zhao	cc76d78673	enh: separate sync read and write events	2023-03-14 20:35:39 +08:00
Benguang Zhao	d679eaf648	enh: update pMnode->applied only when pMsg->code as zero	2023-03-10 18:10:34 +08:00
Benguang Zhao	96e70c2795	enh: update logging msg in vnodeRestoreFinish	2023-03-09 20:05:19 +08:00
Benguang Zhao	5e53b1225b	enh: finish restore with commit and applied indexes instead of num of items in apply queue	2023-03-09 19:35:42 +08:00
Benguang Zhao	1392711e66	enh: add fsm FpAppliedIndexCb to get the current applied index	2023-03-09 18:14:04 +08:00
Benguang Zhao	9d10739908	enh: send rsp of negotiation failure ahead of apply queue	2023-03-09 16:18:44 +08:00
wangmm0220	e54e12eff0	fix:give error if col is same in schemless & fix json parse error in TD-22903	2023-03-04 11:57:27 +08:00
Shengliang Guan	3b475d4c0d	fix: adjust some log while split	2023-02-03 14:40:19 +08:00
Shengliang Guan	ef3e60c387	Merge branch 'fix/TD-21746' into FIX/TD-21043-main	2023-01-05 15:58:30 +08:00
Shengliang Guan	7e5d97f0da	fix: stop snapshot receiver on sync post close	2023-01-05 12:00:35 +08:00
Benguang Zhao	4031dc1af4	Merge branch main into FIX/TD-21043-main	2023-01-02 16:41:46 +08:00
Shengliang Guan	c2323db00d	fix: allow the ip resolved by fqdn different between dnodes	2022-12-30 17:04:14 +08:00
Benguang Zhao	92e05b8ece	enh: schedule vnodeCommit uniformly distributed	2022-12-27 16:28:44 +08:00
Benguang Zhao	8916722dd7	Merge branch main to FIX/TD-21043-main	2022-12-27 14:50:39 +08:00
Shengliang Guan	794fb5d1b5	fix: handle error if sync buffer is full	2022-12-26 20:40:33 +08:00
Benguang Zhao	fda2f55fe5	Merge branch main to FIX/TD-21043-main	2022-12-26 14:26:25 +08:00
Benguang Zhao	5159d60f56	enh: vnodeCommit on consensus only	2022-12-23 20:16:32 +08:00
Shengliang Guan	48b6bd438d	fix: restart snapshot sender on receiver is restart	2022-12-22 17:30:02 +08:00
Shengliang Guan	9c8b194c34	refact: set FpSnapshotStopRead return type to void	2022-12-20 15:07:27 +08:00
Shengliang Guan	12b6cf15a0	refact: set FpGetSnapshotInfo return type to void	2022-12-20 14:57:04 +08:00
Shengliang Guan	4db6b043c6	fix: reduce the frequency of retry in sync not ready case while alter db	2022-12-14 19:01:31 +08:00
Shengliang Guan	60bab9ae55	refact: post sem in vnode while sync timeout	2022-12-14 16:09:28 +08:00
Shengliang Guan	2b256542a5	refact: add vnode timer	2022-12-14 09:14:40 +08:00