Haojun Liao
|
2ca6726922
|
refactor: check return value for each function.
|
2024-07-18 22:52:32 +08:00 |
|
Haojun Liao
|
b35d107bf9
|
refactor: check return value for each function.
|
2024-07-17 18:55:04 +08:00 |
|
Haojun Liao
|
0100bb51b9
|
other: merge 3.0
|
2024-07-17 17:36:49 +08:00 |
|
Haojun Liao
|
2aa4d6028b
|
refactor: check return value for each function.
|
2024-07-17 16:56:36 +08:00 |
|
Haojun Liao
|
30186f466b
|
refactor: check return value for each function.
|
2024-07-17 16:47:56 +08:00 |
|
Haojun Liao
|
552e59f42b
|
refactor: check return value for each function.
|
2024-07-17 15:40:00 +08:00 |
Hongze Cheng
|
35606a5658
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into enh/TD-30987-3
|
2024-07-17 13:07:07 +08:00 |
|
Hongze Cheng
|
64363627fe
|
enh: refact tqueue code
|
2024-07-16 17:30:32 +08:00 |
|
Haojun Liao
|
691c1dfa7d
|
fix(stream): check dst stable schema before generating auto create table.
|
2024-07-16 14:45:09 +08:00 |
dapan1121
|
e527f2fd0b
|
fix: validate function return value
|
2024-07-12 15:22:39 +08:00 |
|
Haojun Liao
|
bdced636b3
|
fix(stream): free task state when stopping stream tasks.
|
2024-07-08 18:20:35 +08:00 |
|
Haojun Liao
|
6e15c16cf7
|
fix(stream): check the set consensus-checkpointId ts.
|
2024-07-08 14:33:28 +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
|
2c86e3940f
|
fix(stream): fix memory leak.
|
2024-07-01 17:43:10 +08:00 |
|
Haojun Liao
|
f09be802ea
|
other: merge 3.0
|
2024-07-01 13:32:30 +08:00 |
|
Haojun Liao
|
e74b8473f1
|
fix(stream): clear the active checkpoint info after report to mnode.
|
2024-06-28 23:40:05 +08:00 |
|
Haojun Liao
|
5585a141d5
|
fix(stream): set the failed id before clear the checkpoint info.
|
2024-06-28 23:16:03 +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
|
21e1763ff4
|
fix(stream): set correct flag for checkpoint.
|
2024-06-22 11:16:20 +08:00 |
|
Haojun Liao
|
e7105edaa4
|
fix(stream): disable pause if task is un-init.
|
2024-06-21 14:14:44 +08:00 |
|
Haojun Liao
|
4490f40c96
|
fix(stream): do some internal refactor.
|
2024-06-14 14:43:57 +08:00 |
|
Haojun Liao
|
0f8c0fa8cb
|
fix(stream): add dispatch data monitor to handle the network broken problem that may cause the stream process frozen.
|
2024-06-13 14:56:20 +08:00 |
|
Haojun Liao
|
cbf8b363fc
|
fix(stream): update checkpoint info by using trans.
|
2024-06-10 00:46:01 +08:00 |
|
Haojun Liao
|
1e47cb7eba
|
other: update the test case.
|
2024-06-07 11:15:23 +08:00 |
|
Haojun Liao
|
4fc21cc8b0
|
refactor: do some internal refactor.
|
2024-06-04 10:08:18 +08:00 |
|
Haojun Liao
|
3b3ed1c30c
|
fix(stream): add monitor for checkpoint-ready msg recv status.
|
2024-06-03 16:45:37 +08:00 |
|
Haojun Liao
|
31317c4895
|
fix(stream): set the checkpoint ready info for only one task in stream.
|
2024-06-01 23:20:43 +08:00 |
|
Haojun Liao
|
2a8270f9c8
|
fix(stream): track the checkpoint-ready msg on the upstream tasks.
|
2024-06-01 18:26:45 +08:00 |
|
Haojun Liao
|
76b43dc072
|
fix(stream): 1. check the checkpoint-trigger rsp, 2. set the error code in the message body, 3. follower nodes not handle the checkpoint-trigger retrieve request.
|
2024-05-31 14:32:55 +08:00 |
|
Haojun Liao
|
ee4e4c0e6d
|
refactor: do some internal refactor.
|
2024-05-31 09:17:20 +08:00 |
|
Haojun Liao
|
d1d868f239
|
refactor: do some internal refactor and set the pActiveInfo for rsma.
|
2024-05-29 00:08:29 +08:00 |
|
Haojun Liao
|
be107b204c
|
enh(stream): support retrieve checkpoint data remotely when start stream tasks in vnodes.
|
2024-05-28 09:54:22 +08:00 |
|
Haojun Liao
|
be39044b66
|
fix(stream): add more info
|
2024-05-22 11:04:54 +08:00 |
|
Haojun Liao
|
abd90c733a
|
fix(stream): remove backend files only after the in-memory task is dropped.
|
2024-05-15 14:24:35 +08:00 |
|
Haojun Liao
|
7f93ec2c53
|
fix(stream): update the checkpoint info for followers, and some internal refactor.
|
2024-05-11 09:37:02 +08:00 |
|
Haojun Liao
|
db848f7e6b
|
refactor: do some internal refactor.
|
2024-05-09 10:15:34 +08:00 |
|
Haojun Liao
|
6693efaa85
|
refactor: do some internal refactor.
|
2024-05-09 10:11:37 +08:00 |
|
Haojun Liao
|
c43fbf6fee
|
refactor: do some internal refactor.
|
2024-05-08 11:21:24 +08:00 |
|
Haojun Liao
|
18c66a5491
|
refactor: do some internal refactor.
|
2024-05-06 18:17:38 +08:00 |
|
Haojun Liao
|
7ad7ef7cfc
|
refactor: do some internal refactor.
|
2024-05-06 17:03:41 +08:00 |
|
Haojun Liao
|
a0e68c2bfb
|
refactor: do some internal refactor.
|
2024-04-26 11:14:53 +08:00 |
|
Haojun Liao
|
ae4e2bf671
|
fix(stream): suppress some warnings by ide.
|
2024-04-26 10:00:54 +08:00 |
|
Haojun Liao
|
fae53efed9
|
fix(stream): add some logs for retry for notready/timeout downstream tasks. and do some internal refactor.
|
2024-04-26 09:58:20 +08:00 |
|
Haojun Liao
|
addd2d2a84
|
fix(stream): fix syntax error.
|
2024-04-25 17:06:15 +08:00 |
|
Haojun Liao
|
cd8baa7ba0
|
fix(stream): add log for update task epset, set correct update flag if epset updated.
|
2024-04-25 16:39:11 +08:00 |
|
Haojun Liao
|
b698b8be96
|
fix(stream): pass the address of tmr_h id
|
2024-04-25 09:57:08 +08:00 |
|
Haojun Liao
|
10c792efa2
|
fix(stream):add related fill-history task to be done, when check-rsp moniting quit.
|
2024-04-23 16:55:47 +08:00 |
|
Haojun Liao
|
1adf59e7d8
|
fix(stream): do check when task is paused, and do some internal refactor.
|
2024-04-23 13:53:23 +08:00 |