712 commits

Author	SHA1	Message	Date
Haojun Liao	0cbf88f021	fix(stream): fix memory leak.	2024-07-08 14:51:08 +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	6a1555e893	refactor: do some internal refactor.	2024-07-05 18:06:00 +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	78993d9c55	fix(stream): update logs.	2024-07-05 09:00:01 +08:00
Haojun Liao	db4a00c74e	fix(stream): not restart for reset task status.	2024-07-05 08:55:40 +08:00
Haojun Liao	47b0a0464e	fix(stream): send checkpoint-source-rsp to mnode before reset task status.	2024-07-04 15:21:16 +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	2c86e3940f	fix(stream): fix memory leak.	2024-07-01 17:43:10 +08:00
Haojun Liao	025437df0c	fix(stream): fix error in checkpoint consensus.	2024-06-27 19:25:18 +08:00
Haojun Liao	48bf5eb4d8	other: merge 3.0	2024-06-27 19:23:06 +08:00
Hongze Cheng	b761bd2e38	enh: port main change to 3.0	2024-06-26 10:32:15 +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	53f9af06ff	fix(stream): fix invalid write.	2024-06-21 15:44:38 +08:00
Haojun Liao	53b51b9b71	fix(stream): fix syntax error.	2024-06-21 15:23:15 +08:00
Haojun Liao	e7105edaa4	fix(stream): disable pause if task is un-init.	2024-06-21 14:14:44 +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	b22679c941	fix(stream): do NOT remove the stream if the stream object is not accessiable, since the deploy trans may not completed yet.	2024-06-11 17:13:44 +08:00
Haojun Liao	781b644a8c	fix(stream):fix memory leak and update test cases.	2024-06-11 16:34:47 +08:00
Haojun Liao	3b537367c9	fix(stream): fix memory leak.	2024-06-11 15:21:48 +08:00
Haojun Liao	0245d82e54	fix(stream): make sure that the unit test case can work.	2024-06-11 14:26:29 +08:00
Haojun Liao	00eb621825	fix(stream): do scan checkpoint-report in write queue.	2024-06-11 14:09:50 +08:00
Haojun Liao	68aac5dee1	other: fix syntax error.	2024-06-11 11:12:24 +08:00
Haojun Liao	cbf8b363fc	fix(stream): update checkpoint info by using trans.	2024-06-10 00:46:01 +08:00
Haojun Liao	d0675a660e	fix(stream): init the node list and task list when starting mnode.	2024-06-07 17:53:53 +08:00
Haojun Liao	34205ba62c	refactor: do some internal refactor.	2024-06-07 10:09:40 +08:00
Haojun Liao	88e77d6bc6	fix(stream): remove expired stream in buf.	2024-06-06 23:54:48 +08:00
Haojun Liao	0e9f720cc4	fix(stream):add logs.	2024-06-06 11:27:20 +08:00
Haojun Liao	1e33a1f408	fix(stream): fix memory leak.	2024-06-05 11:43:39 +08:00
Haojun Liao	82293406f1	fix(stream): fix syntax error.	2024-06-05 09:14:33 +08:00
Haojun Liao	29648be30d	fix(stream): add the new node info when adding stream tasks.	2024-06-04 23:28:08 +08:00
Haojun Liao	4fc21cc8b0	refactor: do some internal refactor.	2024-06-04 10:08:18 +08:00
Haojun Liao	f13dc1858a	fix(stream): disable stream checkpoint when related fill-history task exists.	2024-06-03 09:54:28 +08:00
Haojun Liao	ee4e4c0e6d	refactor: do some internal refactor.	2024-05-31 09:17:20 +08:00
Haojun Liao	0946f25e5f	fix(stream): fix syntax error.	2024-05-29 22:36:22 +08:00
Haojun Liao	becc4cb368	enh(stream): limit the concurrent started checkpoint tasks.	2024-05-29 19:29:26 +08:00
Haojun Liao	89fb56e77d	other: merge 3.0	2024-05-24 11:41:51 +08:00
Haojun Liao	0c61fb20d6	fix(stream): check if outputQ is full before execute the scan history task. if it is full, idle for 5 sec.	2024-05-23 17:22:29 +08:00
Haojun Liao	317742acc1	fix(stream): adjust buf size.	2024-05-22 13:29:38 +08:00
Haojun Liao	565d1f408c	fix(stream): adjust buf size, and avoid overflow	2024-05-22 13:26:49 +08:00
Haojun Liao	77852fa702	fix(stream): avoid data overflow and fix test cases.	2024-05-22 13:20:45 +08:00
Haojun Liao	be39044b66	fix(stream): add more info	2024-05-22 11:04:54 +08:00
kailixu	04c0c8b6cd	enh(grant): refine error code	2024-05-21 15:26:29 +08:00
Haojun Liao	f6af165d9a	refactor(stream): add more info in info-meta	2024-05-21 10:09:55 +08:00
Haojun Liao	d73fd5492a	fix(test): update test case.	2024-04-30 14:24:20 +08:00