Jinqing Kuang
fc2d2672b9
feat(stream)[TS-5469]: add more stream event notifications
...
- Add event notifications for all window types
- Implement window invalidation notifications
- Add statistics for event notification delivery
2025-02-16 11:07:16 +08:00
Jinqing Kuang
eb5d463490
feat(stream)[TS-5469]. add support for window event notifications in stream processing
...
- Introduce new syntax to specify notification type and destination address
- Collect relevant event information during window computations
- Implement websocket-based notification delivery to the specified address
2025-01-21 17:39:46 +08:00
wangmm0220
cae21da2d4
fix:[TS-5906]clear meta cache for subscription if tag is changed
2025-01-14 15:35:43 +08:00
dapan1121
2bd493f77b
fix: return code issues
2024-12-11 19:18:50 +08:00
dapan1121
85fc4dfc2b
fix: data sink memory issues
2024-11-15 10:16:15 +08:00
dapan1121
371094cc13
Merge remote-tracking branch 'origin/3.0' into feat/TD-30268
2024-11-08 10:13:20 +08:00
dapan1121
c5c85efeb5
enh: adjust mode and retire policy
2024-11-06 19:26:14 +08:00
54liuyao
719a3faa12
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-11-06 11:13:15 +08:00
Shengliang Guan
0be118c0aa
Merge pull request #28408 from taosdata/enh/TD-32181/client
...
Enh/td 32181/client
2024-11-06 09:42:05 +08:00
54liuyao
b6d16eccdb
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-10-30 14:54:42 +08:00
Shengliang Guan
ea9ed2e538
Merge pull request #28300 from taosdata/enh/TS-5441-3.0
...
enh:[TS-5441] cost too long in tmq write meta data by cache meta and vg info
2024-10-30 13:43:41 +08:00
54liuyao
d065d71821
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-10-30 10:09:48 +08:00
54liuyao
424e574e94
fix issue
2024-10-28 11:09:56 +08:00
54liuyao
6b2d338a20
enh(executor):avoid use dangerous functions
2024-10-25 13:47:09 +08:00
dapan1121
4f3484b823
Merge remote-tracking branch 'origin/3.0' into feat/TD-30268
2024-10-24 16:49:38 +08:00
xsren
e8835c2caa
blockDataCheck
2024-10-23 15:37:49 +08:00
54liuyao
e9550a6b2c
feat(stream):save force window close scan range
2024-10-18 15:40:37 +08:00
wangmm0220
bc05289192
enh:[TS-5441] cost too long in tmq write meta data by cache meta and vg info
2024-10-18 09:28:16 +08:00
wangmm0220
10436cacff
enh:[TS-5441] cost too long in tmq write meta data by cache meta and vg info
2024-10-15 16:17:58 +08:00
wangmm0220
61531e7339
enh:[TS-5441] cost too long in tmq write meta data by cache meta and vg info
2024-10-14 13:55:45 +08:00
54liuyao
9377450199
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-10-14 13:55:05 +08:00
54liuyao
ef0782d378
fix(stream): check reload function
2024-10-11 15:27:29 +08:00
wangmm0220
42b7520d34
enh:[TS-5441] cost too long in tmq write meta data by cache meta and vg info
2024-10-10 18:27:42 +08:00
54liuyao
1ce919b5b7
fix(stream):check release function of stream
2024-10-10 17:17:21 +08:00
wangmm0220
e6bf8dcfde
enh:[TS-5441] cost too long in tmq write meta data by cache meta and vg info
2024-10-09 18:10:43 +08:00
54liuyao
d13819bbf4
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-30 09:05:46 +08:00
54liuyao
d44529e62f
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-25 15:12:15 +08:00
Haojun Liao
4e4003c5a7
Merge branch '3.0' into fix/3_liaohj
2024-09-24 18:36:18 +08:00
Haojun Liao
2b78b660bd
refactor: update the error logs.
2024-09-24 18:19:47 +08:00
54liuyao
ecaa66e53f
set watermark and interval
2024-09-20 15:30:44 +08:00
lyh250-666
116844208d
enh:modify error code passing
2024-09-20 13:23:44 +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
54liuyao
c4566f98b8
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-18 16:26:37 +08:00
Haojun Liao
b494163f28
refactor: check return value.
2024-09-14 13:39:23 +08:00
Haojun Liao
1a90e9612d
refactor: check return value.
2024-09-13 23:04:41 +08:00
54liuyao
de44c5dc5e
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-13 11:13:04 +08:00
Haojun Liao
c13248dd4e
refactor: remove void.
2024-09-12 19:23:05 +08:00
54liuyao
7c32cc7796
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-12 09:08:40 +08:00
dapan1121
dc983b9a39
fix: add block data check
2024-09-10 16:56:36 +08:00
54liuyao
75727e47b5
remove assert
2024-09-09 17:58:40 +08:00
54liuyao
88d01d8980
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-09 11:21:23 +08:00
Haojun Liao
199de25410
fix(stream): fix syntax error.
2024-09-08 15:17:08 +08:00
Haojun Liao
23ccbbdda5
fix(stream): fix syntax error.
2024-09-08 15:10:54 +08:00
Haojun Liao
b3e5997336
fix(stream): reset error code.
2024-09-08 14:54:08 +08:00
54liuyao
7501c5a865
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-30837
2024-09-06 13:26:23 +08:00
Haojun Liao
2544f0313e
Merge pull request #27672 from taosdata/fix/ly_res
...
enh(query):remove void for operator
2024-09-06 09:49:10 +08:00
Haojun Liao
1e57724533
Merge pull request #27688 from taosdata/fix/3_liaohj
...
fix(stream): handle continuous retrieve during checkpoint procedure.
2024-09-06 09:11:08 +08:00
Haojun Liao
277528996e
fix(stream): handle continuous retrieve during checkpoint procedure.
2024-09-05 16:04:36 +08:00
54liuyao
d3e4203dcb
enh(query):remove void for operator
2024-09-04 18:37:41 +08:00