facetosea
b5916c88d5
fix: print log
2025-05-12 17:36:09 +08:00
dapan1121
a4869f5263
fix: compile issues
2025-05-12 17:14:35 +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
dapan1121
fd405c6920
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw6
2025-05-12 15:20:46 +08:00
dapan1121
73d13075b1
enh: add snode failover
2025-05-12 15:19:22 +08:00
wangmm0220
b07d8d2dd0
feat(stream): add interface vnodeProcessStreamGroupColValueReq
2025-05-12 14:33:20 +08:00
Jinqing Kuang
965d33e1ef
fix(stream): fix ts slot id in calc data
2025-05-12 14:20:36 +08:00
Simon Guan
75e2b3917f
Merge branch 'main' into merge/mainto3.0
2025-05-12 11:33:33 +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
Simon Guan
3cfdb304e8
Merge branch 'main' into merge/mainto3.0
2025-05-12 09:01:48 +08:00
wangmm0220
df42d12b06
feat(stream): return calc cols and trigger cols from stream reader
2025-05-10 21:22:11 +08:00
wangjiaming0909
6d6c63a221
new-stream: handle read from cache rsp
2025-05-10 20:30:35 +08:00
facetosea
b62c7976c1
fix: get data from cache
2025-05-10 19:26:27 +08:00
dapan1121
08db53099c
enh: add snode redeploy
2025-05-10 18:36:23 +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
dapan1121
bdcbe1a717
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw5
2025-05-10 17:18:40 +08:00
dapan1121
ca2241f6ad
fix: add snode task redeploy
2025-05-10 17:16:39 +08:00
wangjiaming0909
9bd7381978
stream-runner: runner impl
2025-05-10 15:42:05 +08:00
wangjiaming0909
e9d248f9e7
new-stream: runner notification
2025-05-10 15:42:05 +08:00
wangjiaming0909
b9f4426fde
new-stream: runner handle read from cache
2025-05-10 15:42:05 +08:00
Zhixiao Bao
338072e262
enh: add more feat for stb keep. ( #31019 )
2025-05-10 15:17:22 +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
dongming chen
7840f361dd
enh: update database fetch functions to include status in JSON output ( #31005 )
2025-05-09 15:58:31 +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
factosea
29db253166
fix: safe check
2025-05-09 13:26:31 +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
dapan1121
7e792ee76e
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw5
2025-05-09 11:35:10 +08:00
factosea
64a2fdd7c2
fix: crash, safe check
2025-05-09 11:32:20 +08:00
dapan1121
ee09c9643c
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw5
2025-05-09 11:32:10 +08:00
Simon Guan
f31428d422
Merge branch 'main' into merge/mainto3.0
2025-05-09 09:19:07 +08:00
dongming chen
28fda620c7
feat: add tsRoutineReportInterval and integrate into syncNodeTimerRou… ( #30956 )
2025-05-09 09:16:49 +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
dapan1121
cc7dd3bebc
fix: add stb version and top plan
2025-05-08 15:13:59 +08:00
dapan1121
e76cd4ff5c
fix: add calcCacheScan plan for reader
2025-05-08 15:13:59 +08:00
wangjiaming0909
9fd5f6364c
new-stream: runner impl
2025-05-08 14:58:41 +08:00
wangmm0220
1bb860519f
feat(stream): add logic of fetch rsp for calc
2025-05-08 13:52:45 +08:00
wangmm0220
6f8076092e
feat(stream): add logic of fetch rsp for calc
2025-05-08 11:43:45 +08:00
wangmm0220
58959b5526
feat(stream): add logic of fetch rsp for calc
2025-05-08 11:24:37 +08:00
wangmm0220
e28e48cbf9
feat(stream): add logic of fetch rsp for calc
2025-05-08 10:30:51 +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
dapan1121
77a024f96f
fix: add cache fetch
2025-05-07 19:16:56 +08:00