394 commits

Author	SHA1	Message	Date
yihaoDeng	8023f2bebd	fix stream backend convert	2023-11-16 15:30:01 +08:00
yihaoDeng	de7f2a2d1a	Merge branch '3.0' into enh/refactorBackend	2023-11-13 11:11:28 +08:00
Haojun Liao	9ee9174608	other: merge 3.0	2023-11-11 15:48:31 +08:00
Haojun Liao	3bacd7516e	fix(stream): extact stream nodes list if not initialized.	2023-11-11 15:40:35 +08:00
Haojun Liao	15430f4d50	refactor:	2023-11-11 15:40:33 +08:00
Haojun Liao	5fcef5bd89	refactor:add some logs.	2023-11-11 15:40:32 +08:00
Haojun Liao	77d6fd5394	refactor: do some internal refactor.	2023-11-11 15:39:09 +08:00
yihaoDeng	3e2314b09b	Merge branch '3.0' into enh/refactorBackend	2023-11-10 09:22:16 +08:00
yihaoDeng	15b73354f8	change chkpid gen way	2023-11-09 13:59:21 +08:00
yihaoDeng	98a2ca6bfd	change chkpid gen way	2023-11-09 10:07:24 +08:00
yihaoDeng	06f196b71d	change check out seq	2023-11-09 09:08:41 +08:00
yihaoDeng	0f98f4daa5	change check out seq	2023-11-08 20:29:37 +08:00
yihaoDeng	08e3448498	add seq	2023-11-08 19:54:57 +08:00
yihaoDeng	6ce878948f	Merge branch 'enh/new3.0' into enh/refactorBackend	2023-11-02 20:44:36 +08:00
yihaoDeng	1e96edcdd7	Merge branch 'enh/new3.0' into enh/refactorBackend	2023-11-01 17:30:46 +08:00
yihaoDeng	4c8edb5545	Merge branch 'enh/new3.0' into enh/refactorBackend	2023-11-01 16:07:49 +08:00
dmchen	0ab4e809c5	db and resource	2023-11-01 15:12:45 +08:00
Haojun Liao	1bbad532a7	fix(stream): add more check.	2023-10-30 09:32:40 +08:00
Haojun Liao	91121974d7	fix(stream): do nodeUpdate trans only after check if vnodes are all ready.	2023-10-30 09:32:40 +08:00
Haojun Liao	48202a1e45	fix(stream): set the trans exec sequentially.	2023-10-30 09:32:40 +08:00
Haojun Liao	1a1b9f5ea3	fix(stream): set the trans exec sequentially.	2023-10-30 09:32:40 +08:00
Haojun Liao	c7285c0ede	fix(stream): add expired epset node list for stream tasks in hb to mnode.	2023-10-27 23:41:57 +08:00
Haojun Liao	29b3a7a5e9	refactor: do some internal refactor.	2023-10-27 09:59:53 +08:00
Haojun Liao	38eb5d2f89	refactor(stream): do some internal refactor.	2023-10-27 09:59:53 +08:00
Haojun Liao	b4992a8506	other: add some logs.	2023-10-27 09:59:52 +08:00
Haojun Liao	fa670a93f3	fix(stream): set the retrycode for checkpoint source transaction.	2023-10-27 09:59:52 +08:00
Haojun Liao	454624516c	fix(stream): handle the repeatly issued nodeUpdate msg from dnode.	2023-10-27 09:59:51 +08:00
Haojun Liao	47d4bac57a	fix(stream): remove invalid assert.	2023-10-27 09:55:07 +08:00
Haojun Liao	4845474ea4	refactor: do some internal refactor.	2023-10-27 09:55:06 +08:00
Haojun Liao	5313543a9e	refactor: do some internal refactor.	2023-10-27 09:55:05 +08:00
Haojun Liao	48ff521968	fix(stream): update the nodeEp even during checkpoint trans.	2023-10-27 09:55:02 +08:00
Haojun Liao	1eac7f44c0	fix(stream): fix error in stream.	2023-10-27 09:54:56 +08:00
Haojun Liao	579dd8e6b2	refactor(stream): do some internal refactor.	2023-10-27 09:54:56 +08:00
Haojun Liao	4badb445c4	refactor: do some internal refactor W.R.T. global configurations.	2023-10-27 09:54:07 +08:00
Haojun Liao	a4f6042966	fix(stream): fix error in creating update node trans.	2023-10-27 09:52:14 +08:00
Haojun Liao	ffa798c4fa	enh(stream): add some logs.	2023-10-27 09:52:14 +08:00
yihaoDeng	d46cf878eb	refactor stream backend	2023-10-24 11:53:52 +08:00
yihaoDeng	986a502019	refactor stream backend	2023-10-23 18:22:58 +08:00
yihaoDeng	ca1ffd584d	refactor stream backend	2023-10-23 16:45:17 +08:00
yihaoDeng	9d210ec957	refactor stream backend	2023-10-23 14:06:25 +08:00
yihaoDeng	1a4cfd11a5	Merge branch 'enh/new3.0' into enh/refactorBackend	2023-10-20 15:28:10 +08:00
yihaoDeng	67dc52d2d6	refactor stream checkpoint	2023-10-19 15:19:52 +08:00
Haojun Liao	33d9f772be	other: merge 3.0	2023-10-13 09:06:13 +08:00
Haojun Liao	21fb502690	enh(stream): add trans to reset task status to avoid being frozen in checkpoint status due to doing checkpoint failure of partial tasks.	2023-10-09 20:10:26 +08:00
Haojun Liao	9d5a3b8d78	other: merge stream fix.	2023-10-09 20:10:13 +08:00
Haojun Liao	11d8c8da39	fix(stream): update the sink data.	2023-10-09 20:09:23 +08:00
Haojun Liao	f0c5b5a970	refactor(stream): revised the display info.	2023-10-09 20:09:22 +08:00
Haojun Liao	28008f8263	enh(stream): add more info for sink task.	2023-10-09 20:09:22 +08:00
Haojun Liao	932d93ab35	refactor: wait for more time for future data	2023-10-09 20:09:21 +08:00
Haojun Liao	0ab5d4b342	refactor: do some internal refactor.	2023-10-09 20:09:20 +08:00