facetosea
734e09a22f
fix: table uid hash cache
2025-05-29 11:30:28 +08:00
wangmm0220
3a38149af6
fix(stream): add get OTableInfo interface
2025-05-28 19:41:10 +08:00
wangmm0220
e6dfbf6295
fix(stream): add interface of get vtable info
2025-05-28 18:34:19 +08:00
wangmm0220
1661db33b3
fix(stream): processTag coredump in walCaclRequest
2025-05-28 14:45:48 +08:00
Jing Sima
fa5b70d670
feat: [TS-6100] Parse create stream sql: Sql gen refacotr.
2025-05-28 13:52:56 +08:00
Jinqing Kuang
5f3d1df1fa
Merge branch '3.0' into feat/TS-6100-3.0
2025-05-27 19:31:36 +08:00
Hongze Cheng
430da1f872
enh: add memory usage monitor for vnode ( #31212 )
2025-05-27 16:40:03 +08:00
wangmm0220
9772e9846c
fix(stream): error if %%n with varchar tag
2025-05-26 19:56:41 +08:00
wangmm0220
3aa8c175f5
feat(stream): reset agg operator & reset tsdb reader in fetch request
2025-05-26 14:52:02 +08:00
Jinqing Kuang
cd5ef52a9d
fix(stream): remove unused files
2025-05-26 09:38:40 +08:00
Jinqing Kuang
18566df281
Merge branch '3.0' into kjq-merge
2025-05-24 14:56:21 +08:00
Haojun Liao
11665b6efe
fix(stream): control the global parameters.
2025-05-23 14:36:20 +08:00
Haojun Liao
8b2eb18323
fix(stream): update the stream info for update.
2025-05-23 11:01:28 +08:00
Haojun Liao
02d70186d2
refactor(stream): add parameters to config the stream queue size.
2025-05-22 19:56:49 +08:00
Haojun Liao
f5db6532dc
refactor(stream): add parameters to config the write queue size.
2025-05-22 19:54:54 +08:00
Haojun Liao
4743cc3683
refactor(stream): check for write queue size for sink tasks.
2025-05-22 17:55:47 +08:00
wangmm0220
2d717c3a4f
feat(stream): set tag value in trigger cols
2025-05-22 15:38:32 +08:00
Haojun Liao
231d8b416e
fix(stream): fix memory leak.
2025-05-22 09:55:18 +08:00
wangmm0220
b13967b8f3
feat(stream): move SStorageAPI from stream directory to vnode
2025-05-17 16:00:50 +08:00
wangmm0220
96ab95e33b
feat(stream): add group values
2025-05-17 11:41:46 +08:00
factosea
edcec9f02b
fix: create table has exist
2025-05-17 10:47:56 +08:00
wangmm0220
3f08f95dde
feat(stream): fix col id error
2025-05-16 17:03:55 +08:00
wangmm0220
2891e73399
feat(stream): fix compile error
2025-05-16 16:13:44 +08:00
wangmm0220
a5007823b8
feat(stream): add ctime for getting wal meta
2025-05-16 16:14:42 +08:00
wangmm0220
39015385f9
feat(stream): add some logs
2025-05-16 09:23:52 +08:00
wangmm0220
88414a1b09
feat(stream): use TimeRangeExpr to filter data in tsdb reader
2025-05-15 19:07:42 +08:00
WANG MINGMING
40216c6143
opti(tmq): save tmq offset in vnode commit time & change log level ( #30993 )
2025-05-15 18:15:01 +08:00
wangmm0220
0297c7be2c
feat(stream): add ts slotid/blockId in external window
2025-05-15 14:22:46 +08:00
wangmm0220
9ffe95755b
feat(stream): add interface of getting cols value of groupid
2025-05-15 10:03:57 +08:00
facetosea
0a7ac81aeb
fix: table schema version start from 1
2025-05-14 17:41:51 +08:00
wangmm0220
a1955fb3af
feat(stream): add ast for calc in stream reader
2025-05-14 17:39:02 +08:00
facetosea
11760abea2
fix: subtable schema check when table has exist
2025-05-14 11:12:14 +08:00
Haojun Liao
d02b17be0e
fix(stream): extends the node update check interval. ( #31048 )
2025-05-14 10:15:17 +08:00
wangmm0220
9032653fad
feat(stream): add filter if with external window
2025-05-13 17:57:15 +08:00
wangmm0220
5e7aed840e
feat(stream): add filter if with external window
2025-05-13 10:53:39 +08:00
dapan1121
009e8aa41e
Merge remote-tracking branch 'origin/3.0' into feat/TS-6100-3.0
2025-05-12 16:24:22 +08:00
wangmm0220
b07d8d2dd0
feat(stream): add interface vnodeProcessStreamGroupColValueReq
2025-05-12 14:33:20 +08:00
Hongze Cheng
0dfb4596fb
enh: add another recover mode ( #30985 )
2025-05-12 11:28:07 +08:00
Haojun Liao
e439569455
test(stream): update the test cases. ( #31044 )
2025-05-12 11:25:07 +08:00
facetosea
b0e0d0e565
fix: data insert, table version changed
2025-05-12 10:22:28 +08:00
wangmm0220
df42d12b06
feat(stream): return calc cols and trigger cols from stream reader
2025-05-10 21:22:11 +08:00
wangmm0220
f1155c54ad
feat(stream): return calc cols and trigger cols from stream reader
2025-05-10 18:34:01 +08:00
Jinqing Kuang
4d4544109e
fix(stream): fix history calc of stream trigger task
2025-05-10 18:17:17 +08:00
wangjiaming0909
9bd7381978
stream-runner: runner impl
2025-05-10 15:42:05 +08:00
Jing Sima
84016904ff
fix: [TS-6445] Fix virtual tables not detecting schema changes. ( #30999 )
...
Ensure virtual tables invalidate cached schema metadata and reload it when a schema change (e.g., ALTER VTABLE) is detected. This prevents stale schema references and query errors after structural updates.
2025-05-10 10:34:54 +08:00
wangmm0220
aea901d2c8
fix(stream): add trigger cols
2025-05-09 18:37:54 +08:00
Jinqing Kuang
27d7d71057
fix(stream): fix response type of stream reader task
2025-05-09 14:41:45 +08:00
factosea
9ab3fcd062
fix: datainsert
2025-05-09 14:34:45 +08:00
wangmm0220
441d3d3648
fix(stream): change code from no data to success if wal read out
2025-05-09 12:19:18 +08:00
dongming chen
28fda620c7
feat: add tsRoutineReportInterval and integrate into syncNodeTimerRou… ( #30956 )
2025-05-09 09:16:49 +08:00