Haojun Liao
|
efbc7e1402
|
fix(stream): fix memory leak.
|
2024-01-30 15:35:01 +08:00 |
|
Haojun Liao
|
4970040459
|
refactor: do some internal refactor.
|
2024-01-30 15:22:49 +08:00 |
|
Haojun Liao
|
11c9c7d936
|
refactor: do some internal refactor.
|
2024-01-30 09:17:02 +08:00 |
|
Haojun Liao
|
b714c70434
|
refactor: do some internal refactor.
|
2024-01-29 13:46:33 +08:00 |
|
Haojun Liao
|
9087a0d9d0
|
feat(stream): drop orphan tasks.
|
2024-01-29 11:03:50 +08:00 |
|
Haojun Liao
|
ac08f659c3
|
refactor: remove invalid procedure in fill-history.
|
2024-01-26 16:20:43 +08:00 |
|
Haojun Liao
|
50b59ad936
|
fix(stream): add null ptr check.
|
2024-01-26 16:08:01 +08:00 |
|
Haojun Liao
|
649d26ce72
|
fix(stream): seek to right place to start wal read.
|
2024-01-26 14:14:04 +08:00 |
|
Haojun Liao
|
49aff4571b
|
fix(stream): fix memory leak.
|
2024-01-26 11:33:07 +08:00 |
|
Haojun Liao
|
9b3b03caab
|
refactor: do some internal refactor.
|
2024-01-26 10:22:16 +08:00 |
|
Haojun Liao
|
bc7fe1fe6a
|
refactor: do some internal refactor.
|
2024-01-26 10:08:20 +08:00 |
|
Haojun Liao
|
bd1d1cddaf
|
refactor: do some internal refactor.
|
2024-01-26 10:03:54 +08:00 |
|
Haojun Liao
|
43c035678f
|
refactor: do some internal refactor.
|
2024-01-25 16:55:05 +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
|
8a7e38ad15
|
fix(stream): fix checkpoint failure check.
|
2024-01-24 13:10:53 +08:00 |
|
Haojun Liao
|
0cd84aa587
|
fix(stream): gen checkpoint for single task.
|
2024-01-23 17:51:50 +08:00 |
|
Haojun Liao
|
db474626e6
|
fix(stream): fix memory leak.
|
2024-01-22 11:49:16 +08:00 |
|
Haojun Liao
|
2cc584ff44
|
fix(stream): fix error in check vgId.
|
2024-01-22 11:05:42 +08:00 |
|
Haojun Liao
|
4a5ab10b3d
|
fix(stream): fix memory leak.
|
2024-01-19 20:28:43 +08:00 |
|
Haojun Liao
|
d973f66cea
|
fix(stream): do checkpoint after fill-history task completed.
|
2024-01-19 16:18:02 +08:00 |
|
Haojun Liao
|
996e2939a9
|
refactor: do some internal refactor.
|
2024-01-18 15:58:46 +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
|
719d1d1b90
|
refactor: do some internal refactor.
|
2024-01-18 14:34:18 +08:00 |
|
Haojun Liao
|
f8d0c52483
|
fix(stream): remove this unused drop history task msg and corresponding functions.
|
2024-01-18 14:32:48 +08:00 |
|
Haojun Liao
|
d1dbd03341
|
fix(tsdb): fix invalid set.
|
2024-01-17 17:29:00 +08:00 |
|
Haojun Liao
|
d44dc5bbb2
|
fix(tsdb): fix race condition.
|
2024-01-17 15:20:17 +08:00 |
|
Haojun Liao
|
56eac88349
|
Merge branch '3.0' into fix/3_liaohj
|
2024-01-17 15:14:52 +08:00 |
|
Haojun Liao
|
1ea671e373
|
enh(stream): remove time controller.
|
2024-01-17 14:55:15 +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 |
|
dapan1121
|
66c9c076e8
|
Merge pull request #24469 from taosdata/fix/xsren/TD-28204/whereOptimizeConditional
Fix/xsren/td 28204/where optimize conditional
|
2024-01-17 10:20:51 +08:00 |
|
Haojun Liao
|
a56e589048
|
Merge pull request #24490 from taosdata/fix/TD-28338
fix:[TD-28338]empty varchar value return NULL in tmq
|
2024-01-17 10:09:40 +08:00 |
|
yihaoDeng
|
0d4cc6b8e2
|
fix:[TD-28338]empty varchar value return NULL in tmq
|
2024-01-16 18:46:37 +08:00 |
|
Haojun Liao
|
3d98fc6a67
|
other: merge 3.0
|
2024-01-16 18:29:33 +08:00 |
|
Haojun Liao
|
0280f129bd
|
fix(stream):add some logs.
|
2024-01-16 18:21:29 +08:00 |
|
Haojun Liao
|
882b916940
|
fix(stream): adjust stream trans conflict check.
|
2024-01-16 16:11:04 +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 |
|
Hongze Cheng
|
c40a87ab0e
|
Merge pull request #24319 from taosdata/ENH/TD-28135-3.0
enh: use learner in redistribute vgroup
|
2024-01-16 15:04:52 +08:00 |
|
Haojun Liao
|
9a4b7a6d82
|
fix(stream): remove invalid lock, and fix a typo.
|
2024-01-16 14:52:27 +08:00 |
|
Haojun Liao
|
80793c94c2
|
fix(stream): reset the tasks status before start all tasks, and do some other internal refactor.
|
2024-01-16 14:32:45 +08:00 |
|
xinsheng Ren
|
ae5f540692
|
Merge branch '3.0' into fix/xsren/TD-28204/whereOptimizeConditional
|
2024-01-16 14:28:37 +08:00 |
|
Haojun Liao
|
d1da8ef986
|
Merge pull request #24477 from taosdata/fix/fixResumeBug
fix pause/resume error
|
2024-01-16 14:06:20 +08:00 |
|
Haojun Liao
|
dfe959eb28
|
Merge pull request #24468 from taosdata/fix/3_liaohj
fix(stream): fix deadlock in pause.
|
2024-01-16 12:58:27 +08:00 |
|
Haojun Liao
|
63494de7f9
|
refactor: do some internal refactor.
|
2024-01-16 10:28:07 +08:00 |
|
dapan1121
|
53094f62d8
|
Merge pull request #24359 from taosdata/FIX/TD-27003
Fix : use last row scan when select last_row, last
|
2024-01-16 08:50:23 +08:00 |
|
Yihao Deng
|
7a09ba2630
|
fix pause/resume error
|
2024-01-15 11:56:38 +00:00 |
|
fullhonest
|
fafb5b1f03
|
Fix TD-28018: last row num error where partition by null column
|
2024-01-15 18:29:41 +08:00 |
|
Haojun Liao
|
1296700092
|
Merge pull request #24433 from taosdata/fix/TD-28188
fix:[TD-28188]the epset of snode is error because epset is not initil…
|
2024-01-15 17:05:11 +08:00 |
|
factosea
|
2c0dd3db03
|
fix: memory leak
|
2024-01-15 16:41:52 +08:00 |
|