dmchen
|
073d7f7117
|
fix/TD-30989-scan1-4-2
|
2024-07-27 07:57:50 +00:00 |
wangmm0220
|
44bfb1dddc
|
fix:[TD-31017]process return value in mnode for tmq
|
2024-07-22 17:58:55 +08:00 |
|
wangmm0220
|
862a40afa0
|
fix:[TD-31017]process return value in mnode for tmq
|
2024-07-22 17:30:49 +08:00 |
|
dmchen
|
1c12a16b00
|
fix/TD-30989
|
2024-07-21 00:58:07 +00:00 |
Haojun Liao
|
552e59f42b
|
refactor: check return value for each function.
|
2024-07-17 15:40:00 +08:00 |
wangjiaming0909
|
a75c67efc8
|
rebase with stream sub table name no group id
|
2024-04-16 14:18:10 +08:00 |
|
Haojun Liao
|
dafac591f7
|
enh(stream): add rsp for req-checkpoint
|
2024-02-27 10:53:25 +08:00 |
|
Haojun Liao
|
81a1eac87a
|
fix(stream): add some logs.
|
2024-02-26 22:49:38 +08:00 |
|
Haojun Liao
|
7c8eb21ee5
|
fix(stream): halt the correct task.
|
2024-02-22 15:01:04 +08:00 |
54liuyao
|
af1893d109
|
merge 3.0
|
2024-02-19 18:30:12 +08:00 |
|
wangmm0220
|
ac9582b24a
|
fix:[TD-28567] do not add md5 to the end of subtable if create stream by sma
|
2024-02-19 13:58:58 +08:00 |
|
54liuyao
|
b53dc5602e
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into 3.0
|
2024-02-19 10:58:20 +08:00 |
|
wangmm0220
|
ee96127020
|
fix:conflicts from 3.0
|
2024-02-18 18:38:38 +08:00 |
|
wangmm0220
|
a8e45440c0
|
fix:conflicts from 3.0
|
2024-02-18 18:02:14 +08:00 |
|
Haojun Liao
|
7a18e5910c
|
enh(stream): halt the initial stream tasks when fill-history is set for count window agg
|
2024-02-05 17:51:09 +08:00 |
|
Haojun Liao
|
cb2ea4a721
|
fix(stream): take ver snapshot for all vgroups before launching stream with fill-history option opened.
|
2024-02-01 11:37:57 +08:00 |
|
54liuyao
|
0afed5263e
|
add mid operator retrive
|
2024-01-31 18:09:13 +08:00 |
|
Haojun Liao
|
b74e98b25c
|
fix(stream): set the correct split timestamp for session/state window.
|
2023-12-26 14:17:46 +08:00 |
|
wangmm0220
|
902504b39b
|
fix:partical func parameters for middle interval[checkStreamSTable1.sim]
|
2023-12-22 15:28:02 +08:00 |
|
wangmm0220
|
dd0afef6f2
|
fix:set triggerParams=0 in mid interval
|
2023-12-20 11:00:25 +08:00 |
|
wangmm0220
|
78c8ebae7f
|
fix:remove useless code in split logic plan & random choose vnode in stream task & add test case
|
2023-12-19 16:35:04 +08:00 |
|
wangmm0220
|
3a0af1ea49
|
fix:aggCnt must bigger than 1 & move msg code to the end to be compatible with old version
|
2023-12-19 10:53:46 +08:00 |
|
wangmm0220
|
64f98744e2
|
fix:set trigger parms = 0 in source task if levelPlan != 1
|
2023-12-18 10:57:36 +08:00 |
|
wangmm0220
|
7ba6135f2c
|
fix:error in split plan
|
2023-12-12 16:37:22 +08:00 |
|
wangmm0220
|
2e596c1376
|
opti:build task logic
|
2023-12-11 14:19:55 +08:00 |
|
wangmm0220
|
d6114f90de
|
feat:add configure for agg cnt
|
2023-12-08 19:00:10 +08:00 |
|
wangmm0220
|
2a506b3e5e
|
feat:add multi level agg operator for stream task
|
2023-12-08 18:48:34 +08:00 |
|
wangmm0220
|
acfcfdc8b6
|
opti:build task logic in stream
|
2023-12-08 15:51:01 +08:00 |
|
wangmm0220
|
b36665c9d6
|
opti:build task logic in stream
|
2023-12-08 15:48:44 +08:00 |
|
Haojun Liao
|
43e6722fd8
|
refactor: refactor the stream trans conflict check
|
2023-11-22 08:38:32 +08:00 |
Haojun Liao
|
f76417535c
|
Merge pull request #23451 from taosdata/fix/TD-26685-3.0
fix:print log if assert & check epoch when update epoch
|
2023-11-01 15:32:25 +08:00 |
|
wangmm0220
|
fc228d65f2
|
fix:print log if assert & check epoch when update epoch
|
2023-10-31 15:36:40 +08:00 |
|
Haojun Liao
|
8729bdac1e
|
fix(stream): fix bugs caused by refactor.
|
2023-10-27 09:54:57 +08:00 |
|
Haojun Liao
|
af2c0c95e9
|
refactor: do some internal refactor.
|
2023-10-09 20:10:22 +08:00 |
|
Haojun Liao
|
583ac1fc45
|
refactor: do some internal refactor.
|
2023-10-09 20:09:20 +08:00 |
|
Haojun Liao
|
19042cdea6
|
fix(stream): fix invalid param.
|
2023-10-09 20:09:19 +08:00 |
|
Haojun Liao
|
f9113ab7b0
|
fix(stream): fix invalid param.
|
2023-10-09 20:09:11 +08:00 |
|
Haojun Liao
|
bb4ba54f28
|
fix(stream): enable new time range for stream task.
|
2023-10-09 20:09:09 +08:00 |
|
Haojun Liao
|
c759d90bf6
|
enh(stream): optimize the stream status when creating without fill-history option.
|
2023-10-09 20:09:09 +08:00 |
|
Haojun Liao
|
dfe8641c0c
|
refactor: optimize the fill-history task launch policy, and do some other internal refactor.
|
2023-10-09 20:08:52 +08:00 |
|
Haojun Liao
|
ab17bfdf09
|
refactor: do some internal refactor.
|
2023-10-07 19:16:55 +08:00 |
|
Haojun Liao
|
5718158fc0
|
refactor: do some internal refactor.
|
2023-10-01 22:27:29 +08:00 |
|
Haojun Liao
|
f3275f76e8
|
fix(stream): fix invalid param.
|
2023-09-28 23:31:07 +08:00 |
|
Haojun Liao
|
c14873401f
|
fix(stream): fix invalid param.
|
2023-09-28 23:26:46 +08:00 |
|
Haojun Liao
|
f2d8431619
|
fix(stream): enable new time range for stream task.
|
2023-09-28 18:26:52 +08:00 |
|
Haojun Liao
|
80ec77cbb6
|
enh(stream): optimize the stream status when creating without fill-history option.
|
2023-09-28 11:23:03 +08:00 |
|
Haojun Liao
|
e13efd5b04
|
refactor: optimize the fill-history task launch policy, and do some other internal refactor.
|
2023-09-27 14:00:48 +08:00 |
dapan1121
|
cc17848b78
|
fix: merge 3.0 to main
|
2023-09-01 13:24:47 +08:00 |
|
Haojun Liao
|
cc8b2263cb
|
fix(stream): fix error in heartbeat from vnode.
|
2023-08-22 13:37:38 +08:00 |
|
Haojun Liao
|
f633c7fe2b
|
other: merge 3.0.
|
2023-08-10 11:56:30 +08:00 |