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 |
|
Haojun Liao
|
d4bab8c09b
|
refactor: do some internal refactor.
|
2024-01-25 16:53:30 +08:00 |
|
Haojun Liao
|
dc1ea9f9a1
|
fix(stream): clear htask info when unregistering the task.
|
2024-01-24 16:23:47 +08:00 |
|
Haojun Liao
|
b8856931d8
|
fix(stream): fix syntax error.
|
2024-01-24 13:11:36 +08:00 |
|
Haojun Liao
|
8a7e38ad15
|
fix(stream): fix checkpoint failure check.
|
2024-01-24 13:10:53 +08:00 |
|
Haojun Liao
|
d973f66cea
|
fix(stream): do checkpoint after fill-history task completed.
|
2024-01-19 16:18:02 +08:00 |
|
Haojun Liao
|
76e6c453e7
|
enh(stream): send msg to mnode when the transferring state completed.
|
2024-01-18 15:43:36 +08:00 |
Haojun Liao
|
fc16d26da2
|
Merge pull request #24488 from taosdata/fix/3_liaohj
fix(stream): fix some errors and do some internal refactor.
|
2024-01-17 14:25:32 +08:00 |
|
Haojun Liao
|
8ede6d87ce
|
refactor: do some internal refactor.
|
2024-01-16 15:40:40 +08:00 |
jiajingbin
|
d59ede5196
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-28032
|
2024-01-16 15:05:13 +08:00 |
|
Haojun Liao
|
63494de7f9
|
refactor: do some internal refactor.
|
2024-01-16 10:28:07 +08:00 |
|
Haojun Liao
|
143e6a13af
|
fix(stream): fix deadlock in pause.
|
2024-01-15 14:37:24 +08:00 |
|
Haojun Liao
|
e012bc4bde
|
refactor: do some internal refactor.
|
2024-01-15 11:28:36 +08:00 |
|
Haojun Liao
|
6d37e596ec
|
refactor: do some internal refactor.
|
2024-01-04 18:47:49 +08:00 |
|
Haojun Liao
|
185fa75376
|
enh(stream): add task into timer to be idle during exec when the corresponding output queue is full.
|
2024-01-03 17:59:42 +08:00 |
wangmm0220
|
8add4dc177
|
fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line
|
2024-01-02 18:37:29 +08:00 |
|
Haojun Liao
|
84583580e2
|
fix(stream): transfer the checkpoint trans id.
|
2023-12-21 19:12:49 +08:00 |
|
Haojun Liao
|
4f852704f5
|
fix(stream): send checkpoint complete msg to mnode when dropping it.
|
2023-12-17 02:06:01 +08:00 |
yihaoDeng
|
08eeee0794
|
Merge branch '3.0' into enh/refactorBackend
|
2023-11-28 11:52:49 +08:00 |
|
wangmm0220
|
06e2fbfb1c
|
fix:conflicts from 3.0
|
2023-11-27 17:53:53 +08:00 |
|
wangmm0220
|
70c5d36103
|
opti:extract common logic from snode & vnode to tqCommon
|
2023-11-27 17:49:09 +08:00 |
|
yihaoDeng
|
e9bec34c44
|
Merge branch '3.0' into enh/refactorBackend
|
2023-11-27 10:01:12 +08:00 |
|
wangmm0220
|
d249892b2a
|
fix:conflicts from 3.0
|
2023-11-23 20:29:46 +08:00 |
|
Haojun Liao
|
2e922fefc6
|
fix(stream): reduce the sink throughput. and fix the bug in status check.
|
2023-11-23 18:04:09 +08:00 |
|
yihaoDeng
|
6129ebc294
|
Merge branch '3.0' into enh/refactorBackend
|
2023-11-23 17:41:37 +08:00 |
|
wangmm0220
|
15d75a0497
|
fix:spelling errors
|
2023-11-23 09:17:54 +08:00 |
|
wangmm0220
|
9a09e318ca
|
opti:common message process logic in vnode and snode
|
2023-11-22 16:53:33 +08:00 |
|
yihaoDeng
|
a92602b667
|
fix mem leak
|
2023-11-21 15:23:28 +08:00 |
|
yihaoDeng
|
de7f2a2d1a
|
Merge branch '3.0' into enh/refactorBackend
|
2023-11-13 11:11:28 +08:00 |
|
Haojun Liao
|
97772e9aab
|
fix(stream): the checkpoint version can only be updated when generating checkpoint.
|
2023-11-11 15:40:05 +08:00 |
|
yihaoDeng
|
3abf0ae4b2
|
Merge branch 'feat/TD-26060' into enh/refactorBackend
|
2023-11-08 17:31:16 +08:00 |
|
Haojun Liao
|
884770dab1
|
fix(stream): fix syntax error.
|
2023-11-07 17:12:06 +08:00 |
|
Haojun Liao
|
e13f003b90
|
refactor: do some internal refactor.
|
2023-11-05 01:23:23 +08:00 |
|
yihaoDeng
|
4c8edb5545
|
Merge branch 'enh/new3.0' into enh/refactorBackend
|
2023-11-01 16:07:49 +08:00 |
|
yihaoDeng
|
ee6b620597
|
fix mem leak
|
2023-10-30 17:29:32 +08:00 |
|
Haojun Liao
|
c7285c0ede
|
fix(stream): add expired epset node list for stream tasks in hb to mnode.
|
2023-10-27 23:41:57 +08:00 |
|
Haojun Liao
|
0d4892f25b
|
fix(stream): fix bugs caused by refactor sm.
|
2023-10-27 09:55:00 +08:00 |
|
Haojun Liao
|
a31613ae95
|
refactor: add ref in log.
|
2023-10-27 09:54:59 +08:00 |
|
Haojun Liao
|
e1f6043eed
|
fix(stream): fix bugs caused by refactor sm.
|
2023-10-27 09:54:57 +08:00 |
|
Haojun Liao
|
1eac7f44c0
|
fix(stream): fix error in stream.
|
2023-10-27 09:54:56 +08:00 |
|
Haojun Liao
|
579dd8e6b2
|
refactor(stream): do some internal refactor.
|
2023-10-27 09:54:56 +08:00 |
|
Haojun Liao
|
6f3c0d17cc
|
refactor(stream): add state machine to manage the state of stream tasks.
|
2023-10-27 09:54:49 +08:00 |
|
Haojun Liao
|
596eb073b7
|
refactor(stream): do some internal refactor.
|
2023-10-27 09:54:48 +08:00 |
|
Haojun Liao
|
2409a17517
|
refactor(stream): do some internal refactor.
|
2023-10-27 09:54:44 +08:00 |
|
Haojun Liao
|
164159f293
|
enh(stream): add parameter to limit the stream sink task.
|
2023-10-27 09:54:07 +08:00 |
|
Haojun Liao
|
a4f6042966
|
fix(stream): fix error in creating update node trans.
|
2023-10-27 09:52:14 +08:00 |
|
yihaoDeng
|
db0f6258fe
|
fix stream case error
|
2023-10-25 19:38:22 +08:00 |
|
yihaoDeng
|
1a4cfd11a5
|
Merge branch 'enh/new3.0' into enh/refactorBackend
|
2023-10-20 15:28:10 +08:00 |
|
yihaoDeng
|
2004c1a346
|
fix transfer crash
|
2023-10-17 18:19:52 +08:00 |