Commit graph

215 commits

Author SHA1 Message Date
Haojun Liao
57a2471cc6 fix(stream): add missing release 2025-02-15 00:03:33 +08:00
Haojun Liao
694b6385d5 refactor(stream): adjust reset and mark failed Id. 2025-02-09 21:40:33 +08:00
Haojun Liao
093233203d
Revert "refactor(stream): do some internal refactor ." 2025-01-24 17:11:15 +08:00
Haojun Liao
3223cc0287 other: add todo 2025-01-09 18:37:05 +08:00
Shengliang Guan
e99b888654 Merge branch 'main' into merge/mainto3.0 2024-12-09 19:06:06 +08:00
Haojun Liao
43ad35f911 refactor: adjust the lock procedure for unregister stream tasks. 2024-12-06 09:20:39 +08:00
Shengliang Guan
6db8a25c98 Merge branch 'main' into merge/mainto3.0 2024-11-27 22:31:17 +08:00
Haojun Liao
d397c9a9b7 fix(stream): remove failed task in hash table and array list. 2024-11-22 19:22:37 +08:00
Haojun Liao
b74a1bc726 refactor: update logs, and set correct vgId. 2024-11-15 13:48:42 +08:00
Haojun Liao
fd1996a1d1 fix(stream): fix error in build msg. 2024-11-15 01:27:31 +08:00
Haojun Liao
f65651f6ef fix(stream): update the msg encoder. 2024-11-15 00:19:35 +08:00
Haojun Liao
b2b5a14d9d fix(stream): reset task add the failed chkptId info. 2024-11-14 17:38:40 +08:00
Haojun Liao
3b129f7e36 fix(stream): alwasy return success for resume req. 2024-11-13 19:35:01 +08:00
Haojun Liao
67a547f65a fix(stream): alwasy return success for resume req. 2024-11-13 13:46:23 +08:00
54liuyao
ba31bf2c52 Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837 2024-11-06 09:42:50 +08:00
Haojun Liao
b1ad121bae fix(stream): release task before returning. 2024-10-31 14:49:16 +08:00
Haojun Liao
4802f59dfe fix(stream): use the refId in stream meta list, in order to avoid access already freed stream tasks. 2024-10-27 15:49:40 +08:00
54liuyao
e825d74213 Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837 2024-10-17 17:12:00 +08:00
Haojun Liao
dd05353b74 refactor: do some internal refactor. 2024-10-16 22:07:37 +08:00
Haojun Liao
5c1cffed69 fix(stream): add some logs. 2024-10-10 15:54:15 +08:00
54liuyao
c9308e7482 Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837 2024-09-30 17:12:25 +08:00
yihaoDeng
57f7145878 formate qid 2024-09-29 17:56:11 +08:00
Haojun Liao
f3b42fd9d1 enh(stream): generate the force_window_close trigger block. 2024-09-20 19:18:35 +08:00
54liuyao
e53fafc08f Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837 2024-09-20 15:31:03 +08:00
lyh250-666
ae7dde1aa2 enh:modify error code passing 2024-09-19 19:51:51 +08:00
Haojun Liao
c5eca0486e Merge remote-tracking branch 'origin/fix/TD-30837' into fix/TD-30837
# Conflicts:
#	source/dnode/vnode/src/tq/tq.c
#	source/libs/stream/inc/streamInt.h
#	source/libs/stream/src/streamSched.c
2024-09-19 16:39:54 +08:00
Haojun Liao
e1d8e98b11 feat(stream): support the force_window_close trigger. 2024-09-19 16:23:51 +08:00
Haojun Liao
3332a0b822 refactor: do some internal refactor. 2024-09-15 01:19:30 +08:00
Haojun Liao
1a90e9612d refactor: check return value. 2024-09-13 23:04:41 +08:00
Haojun Liao
a33015e712 refactor: pass error code to invoker. 2024-09-13 19:35:02 +08:00
Haojun Liao
c13248dd4e refactor: remove void. 2024-09-12 19:23:05 +08:00
Haojun Liao
3d50df7191 refactor: remove void. 2024-09-12 16:05:07 +08:00
Haojun Liao
e0a275f1d4 fix(stream): do some internal refactor and rewrite the error code for encode. 2024-09-12 14:49:35 +08:00
Haojun Liao
06f42443cb refactor: remove void. 2024-09-08 22:49:05 +08:00
Haojun Liao
277528996e fix(stream): handle continuous retrieve during checkpoint procedure. 2024-09-05 16:04:36 +08:00
Haojun Liao
4c91928db3
Merge pull request #27554 from taosdata/fix/syntax
refactor: remove assert
2024-08-31 15:57:27 +08:00
Haojun Liao
fb8867f403 refactor: remove assert. 2024-08-29 19:55:09 +08:00
Haojun Liao
705d778d95
Merge pull request #27539 from taosdata/fix/3_liaohj
refactor: do some internal refactor.
2024-08-29 18:38:05 +08:00
Haojun Liao
5bffb0c675 refactor: do some internal refactor. 2024-08-29 14:21:23 +08:00
Haojun Liao
63ec527e04
Merge pull request #27536 from taosdata/fix/3_liaohj
fix(stream): enable follower update the checkpoint info.
2024-08-29 13:43:06 +08:00
Haojun Liao
40669f4e9c fix(tsdb): 1. repeat send req consensus-checkpoint-id; 2.add more error code to deal with the init event failure, 2024-08-29 11:14:58 +08:00
Pan Wei
8b0a040c64
Merge pull request #27500 from taosdata/enh/TD-31691
Modify error code passing for taosMemoryCalloc function in vnode
2024-08-28 11:24:26 +08:00
lyh250-666
06daf85130 Modify error code passing for taosMemoryCalloc function in vnode 2024-08-27 17:37:01 +08:00
Yihao Deng
e1998d151b update qid log 2024-08-24 10:19:25 +00:00
yihaoDeng
d3ea7ad6d1 change QID log 2024-08-22 10:08:26 +08:00
Haojun Liao
f4bac23906 refactor: do some internal refactor 2024-08-17 01:47:30 +08:00
Haojun Liao
54fdea3173 fix(stream): perform node update when mnode leader/follower switches. 2024-08-15 18:01:28 +08:00
Haojun Liao
3701ded767 fix(stream): remove invalid assert. 2024-08-12 16:56:43 +08:00
Haojun Liao
5ff6397416 fix(stream): update return value check. 2024-08-12 10:25:47 +08:00
Haojun Liao
71b8f67ea6 refactor: do some internal refactor. 2024-08-09 11:37:34 +08:00