facetosea
08ba1864a3
fix: spell error
2025-06-07 17:57:07 +08:00
wangmm0220
4572c0243d
fix(stream): add logic for %%tbname
2025-06-05 17:26:09 +08:00
wangmm0220
e7c84442dc
fix(stream): add get tsdb/wal interface for vtable
2025-06-03 14:09:25 +08:00
facetosea
734e09a22f
fix: table uid hash cache
2025-05-29 11:30:28 +08:00
wangmm0220
e6dfbf6295
fix(stream): add interface of get vtable info
2025-05-28 18:34:19 +08:00
wangmm0220
3aa8c175f5
feat(stream): reset agg operator & reset tsdb reader in fetch request
2025-05-26 14:52:02 +08:00
wangmm0220
a716fabbbc
feat(stream): set tag value in trigger cols
2025-05-22 15:45:57 +08:00
wangmm0220
2d717c3a4f
feat(stream): set tag value in trigger cols
2025-05-22 15:38:32 +08:00
wangjiaming0909
0ffe9e55f3
stream runner force output impl
2025-05-20 03:13:22 +00:00
wangjiaming0909
0c402fbb38
new-stream: runner impl external window and force output
2025-05-16 08:29:34 +00:00
wangjiaming0909
5300a66f5e
new-stream: runner impl
2025-05-16 01:41:31 +00:00
wangmm0220
88414a1b09
feat(stream): use TimeRangeExpr to filter data in tsdb reader
2025-05-15 19:07:42 +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
wangjiaming0909
3db03588bd
impl runner external window operator
2025-05-14 09:55:32 +00:00
wangjiaming0909
ef7d67efe0
new-stream: runner notification
2025-05-14 09:55:07 +00:00
facetosea
0a7ac81aeb
fix: table schema version start from 1
2025-05-14 17:41:51 +08:00
wangjiaming0909
bfdad60c2e
new-stream: external window operator impl
2025-05-12 17:36:10 +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
wangjiaming0909
c853ad990e
new-stream: external window operator
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
facetosea
a11fc0d7cd
fix: data insert, build STSchema
2025-05-09 17:05:56 +08:00
factosea
1fafaae137
fix: save table uid
2025-05-09 10:03:35 +08:00
factosea
e4dd28df92
feat inserter param check
2025-05-08 23:00:37 +08:00
wangmm0220
332d21630c
feat(stream): reset task if fetchMsg.reset is true for calc
2025-05-08 19:53:40 +08:00
wangmm0220
9dfcb4d63b
feat(stream): add logic of fetch rsp for calc
2025-05-08 17:39:12 +08:00
wangjiaming0909
5372df5e22
new-stream: runner impl
2025-05-08 17:36:20 +08:00
wangmm0220
bc1c0f272d
feat(stream): add logic of fetch rsp for calc
2025-05-08 17:27:09 +08:00
factosea
14826a47b8
fix: pointer null
2025-05-08 15:25:20 +08:00
factosea
cd9a532064
feat: data inserter
2025-05-08 15:07:04 +08:00
wangjiaming0909
9fd5f6364c
new-stream: runner impl
2025-05-08 14:58:41 +08:00
factosea
f3027e938e
feat: stream data insert
2025-05-08 09:48:53 +08:00
wangmm0220
f4455b3419
feat(stream): add logic of vnodeProcessStreamWalCalcDataReq
2025-05-07 20:17:14 +08:00
wangmm0220
8f1d8729f7
feat(stream): format code
2025-05-07 19:22:18 +08:00
wangjiaming0909
e95c5a9d85
new-stream: runner impl
2025-05-07 18:14:17 +08:00
wangjiaming0909
1ccc6c69a8
new-stream: runner impl
2025-04-29 15:31:17 +08:00
wangmm0220
c632dcf0c1
feat(stream): add logic of stream reader
2025-04-28 19:21:47 +08:00
wangmm0220
a78b09577a
feat(stream): add thread worker for stream reader
2025-04-28 14:37:05 +08:00
wangmm0220
11b625c63e
feat(stream): add thread worker for stream reader
2025-04-25 18:47:25 +08:00
Jing Sima
9d3ded13d0
fix: [TS-6100] Remove useless code and fix bugs
2025-04-24 18:48:28 +08:00
wangmm0220
5ce115cc23
feat(stream): fix compile error
2025-04-24 18:02:12 +08:00
dapan1121
330cf9982d
fix: compile issues
2025-04-24 09:11:54 +08:00
WANG MINGMING
ca724865b9
fix(stream): parName is null ( #30592 )
2025-04-19 10:26:32 +08:00
wangjiaming0909
163dd33a0a
new-stream: impl stream runner
2025-04-16 18:16:55 +08:00
Jing Sima
ffd0a5eb57
fix: [TD-34205] Fix vtable mem leak ( #30608 )
2025-04-07 18:49:49 +08:00
WANG MINGMING
f398baff66
fix(stream): add null pointer check ( #30614 )
2025-04-03 10:20:54 +08:00
Jinqing Kuang
c82398e175
fix(stream): fix stream processing for virtual tables
...
- Fixed status check in virtual table stream processing
- Fixed multi-way merge logic for super virtual tables
- Fixed generation of target subtable names during merge
2025-03-20 01:15:54 +08:00
Jing Sima
ccaa0b91ae
feat: [TS-4897] Add more test and fix bugs. ( #30208 )
...
* feat: [TS-4897] Fix state window wrong res when all state col is NULL.
* fix: [TD-34074] Forbid decimal type in virtual table.
2025-03-19 17:15:17 +08:00
Haojun Liao
dfe32225de
chore: merge main.
2025-03-17 14:51:11 +08:00
Haojun Liao
ab92886820
fix(stream): reduce the consensus checkpoint id trans. ( #30105 )
...
* fix(stream): reduce the consensus checkpoint id trans.
* refactor(stream): add some logs.
* refactor(stream): set the max checkpoint exec time 30min.
* refactor(stream): add checkpoint-consensus trans conflict check.
* refactor(stream): remove unused local variables.
* fix(stream): fix syntax error.
* fix(stream): 1. fix free memory error 2. continue if put result into dst hashmap failed.
* fix issue
* fix issue
* fix(mnd): follower mnode not processes the timer event.
* fix(stream): print correct error msg.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): truncate long subtable name
* fix(stream): add buffer len.
* refactor(stream): update some logs.
* fix issue
* refactor(stream): update some logs.
* refactor(stream): update some logs.
* fix(stream): check return value.
* fix(stream): fix syntax error.
* fix(stream): check return value.
* fix(stream): update the timer check in mnode.
* fix(stream): add restart stage tracking.
* fix(stream): track the start task stage for meta.
* fix(stream): fix error in log.
* refactor(stream): adjust log info.
* fix mem issue
* fix(stream): check the number of required tasks for consensus checkpointId.
* fix(stream): lock the whole start procedure.
* fix(stream): add lock during start all tasks.
* fix(stream): update logs.
* fix(stream): update logs.
* fix(stream): update logs.
* fix(stream): fix dead-lock.
* fix(stream): fix syntax error.
* fix(stream): not drop the scan-history task.
* fix(stream): fix syntax error.
* fix(stream): wait for executor stop before restarting.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): disable some logs.
* fix(stream): reset the start info if no task left.
---------
Co-authored-by: 54liuyao <54liuyao@163.com>
Co-authored-by: Jinqing Kuang <kuangjinqingcn@gmail.com>
2025-03-17 10:20:17 +08:00
