Haojun Liao
|
4e56b6f9eb
|
fix(stream): fix error in pause/resume procedure.
|
2024-07-02 13:33:31 +08:00 |
|
Haojun Liao
|
2c86e3940f
|
fix(stream): fix memory leak.
|
2024-07-01 17:43:10 +08:00 |
|
Haojun Liao
|
c166c8de70
|
fix(stream): fix memory leak.
|
2024-07-01 16:53:43 +08:00 |
|
Haojun Liao
|
6d64d0e081
|
fix(stream): fix memory leak.
|
2024-07-01 15:34:04 +08:00 |
|
Haojun Liao
|
3ae8916384
|
fix(stream): add more check for checkpoint info update for leader.
|
2024-07-01 14:59:55 +08:00 |
|
Haojun Liao
|
f09be802ea
|
other: merge 3.0
|
2024-07-01 13:32:30 +08:00 |
|
Haojun Liao
|
5c002e4bbe
|
fix(stream):set the srcTaskId for checkpoint-trigger block
|
2024-07-01 08:55:38 +08:00 |
|
Haojun Liao
|
398a1b08ac
|
fix(stream): set the correct rsp msg start position.
|
2024-07-01 08:55:04 +08:00 |
|
Haojun Liao
|
1f8991ec91
|
fix(stream): set the correct rsp msg position.
|
2024-06-29 00:40:57 +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
|
1ffec769b8
|
fix(stream): clear the msgId if send success, and handle the race condition problem.
|
2024-06-28 17:03:14 +08:00 |
|
Haojun Liao
|
79be59d20c
|
fix(stream): reset the status before re-send data.
|
2024-06-28 16:27:31 +08:00 |
|
Haojun Liao
|
67f483430e
|
fix(stream): reset the status before re-send data.
|
2024-06-28 16:25:59 +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
|
5e235b50fa
|
Merge pull request #26295 from taosdata/fix/TD-30720
fix(streamMeta): commit tdb after load tasks
|
2024-06-27 14:04:02 +08:00 |
|
Haojun Liao
|
a44e17d5ea
|
fix(stream): enable to re-send hbmsg if mnode failed to recv this hbmsg.
|
2024-06-26 15:21:14 +08:00 |
Minglei Jin
|
3014c66965
|
fix(streamMeta): commit tdb after load tasks
|
2024-06-26 11:21:31 +08:00 |
|
Hongze Cheng
|
b761bd2e38
|
enh: port main change to 3.0
|
2024-06-26 10:32:15 +08:00 |
|
Haojun Liao
|
b6948dcc4e
|
refactor: do some internal refactor.
|
2024-06-26 10:19:45 +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 |
54liuyao
|
25b150af10
|
fix(stream):fill result immediately after delete data
|
2024-06-25 17:24:59 +08:00 |
Haojun Liao
|
c2ad0a6ec5
|
Revert "fix(stream):fill result immediately after delete data"
|
2024-06-25 16:53:32 +08:00 |
|
Haojun Liao
|
156e3ce109
|
Merge pull request #26267 from taosdata/fix/TD-30585
fix(stream):fill result immediately after delete data
|
2024-06-25 16:46:52 +08:00 |
|
Haojun Liao
|
195469f1dd
|
fix(stream): disable the checkpoint-info-update for tasks in non-checkpoint status
|
2024-06-25 12:57:50 +08:00 |
|
54liuyao
|
a4211efacf
|
calc end key
|
2024-06-24 19:19:15 +08:00 |
|
Haojun Liao
|
6b0b65527f
|
fix(stream): do update the checkpoint info if not in checkpoint status.
|
2024-06-24 19:18:31 +08:00 |
|
Haojun Liao
|
bd8c7d8c93
|
fix(stream): pause not stop the start procedure of stream tasks.
|
2024-06-24 13:25:48 +08:00 |
|
54liuyao
|
2d7d144ca2
|
fix(stream):fill dresultimmediately after delete data
|
2024-06-24 10:56:26 +08:00 |
|
Haojun Liao
|
393369fcd8
|
fix(stream):clear checkpoint-ready msg.
|
2024-06-23 00:40:12 +08:00 |
|
Haojun Liao
|
21e1763ff4
|
fix(stream): set correct flag for checkpoint.
|
2024-06-22 11:16:20 +08:00 |
|
Haojun Liao
|
095510ba41
|
fix(stream): fix deadlock
|
2024-06-21 23:43:25 +08:00 |
|
Haojun Liao
|
94f3c6ec2d
|
fix(stream): fix deadlock
|
2024-06-21 23:40:03 +08:00 |
|
Haojun Liao
|
82febd30a0
|
fix(stream): check the task status checkpoint-ready msg send timer.
|
2024-06-21 18:48:34 +08:00 |
|
Haojun Liao
|
5a9500055d
|
fix(stream): check the task status checkpoint-ready msg send timer.
|
2024-06-21 18:44:54 +08:00 |
|
Haojun Liao
|
5966b4f83f
|
fix(stream): fix error in assert.
|
2024-06-21 17:17:39 +08:00 |
|
Haojun Liao
|
4c4bb0a2e4
|
other: merge 3.0.
|
2024-06-21 16:11:50 +08:00 |
|
Haojun Liao
|
53f9af06ff
|
fix(stream): fix invalid write.
|
2024-06-21 15:44:38 +08:00 |
|
Haojun Liao
|
119001e30b
|
fix(stream): update the retrieve checkpoint-trigger msg.
|
2024-06-21 15:11:48 +08:00 |
|
Haojun Liao
|
e7105edaa4
|
fix(stream): disable pause if task is un-init.
|
2024-06-21 14:14:44 +08:00 |
|
Haojun Liao
|
aea4254d40
|
fix(stream): async start task.
|
2024-06-21 10:37:06 +08:00 |
|
Haojun Liao
|
f8578b4a69
|
fix(stream): fix syntax error.
|
2024-06-21 09:34:18 +08:00 |
|
Haojun Liao
|
ebf2df965c
|
Update streamBackendRocksdb.c
|
2024-06-21 09:28:42 +08:00 |
|
Haojun Liao
|
2cb9644471
|
fix(stream): update the checkpoint info only when the status is normal.
|
2024-06-21 09:23:29 +08:00 |
|
Haojun Liao
|
8fd9baf6f5
|
fix(stream):synchronized upload checkpoint data to snode.
|
2024-06-21 09:11:16 +08:00 |
|
Haojun Liao
|
bf16c596a6
|
fix(stream): fix syntax error.
|
2024-06-21 08:46:09 +08:00 |
|
Haojun Liao
|
096ba251ec
|
Merge branch '3.0' into fix/3_liaohj
|
2024-06-20 23:12:18 +08:00 |
|
Haojun Liao
|
2ecc725b1a
|
fix(stream): not clear check downstream info.
|
2024-06-20 21:31:23 +08:00 |
|
Haojun Liao
|
151fc212b8
|
Merge pull request #26218 from taosdata/fix/3_liaohj
fix(stream): clear the local backend default directory
|
2024-06-20 18:26:28 +08:00 |