Haojun Liao
|
5718158fc0
|
refactor: do some internal refactor.
|
2023-10-01 22:27:29 +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
|
c9576d7a85
|
fix(stream): transfer state when all downstream rsp already.
|
2023-09-25 17:31:38 +08:00 |
Haojun Liao
|
dbc53069db
|
Merge branch 'main' into fix/liaohj
|
2023-09-25 10:41:18 +08:00 |
|
Haojun Liao
|
1af95969b2
|
fix(stream): adjust nodeUpdate check interval.
|
2023-09-25 10:40:30 +08:00 |
|
Haojun Liao
|
7380151322
|
fix(stream): remove invalid node.
|
2023-09-22 11:45:46 +08:00 |
|
Haojun Liao
|
198e6bb023
|
enh(stream): add stage info for streamt tasks.
|
2023-09-22 10:36:15 +08:00 |
|
Haojun Liao
|
92f18989df
|
fix(stream): remove invalid cached task info in buffer.
|
2023-09-20 19:19:04 +08:00 |
|
Haojun Liao
|
5e3a268b6d
|
enh(stream): add info in log.
|
2023-09-20 13:15:50 +08:00 |
dm chen
|
4497a01168
|
Merge branch 'main' into feat/TD-26127-audit-sql
|
2023-09-20 11:13:34 +08:00 |
|
Haojun Liao
|
b4419bda65
|
enh(stream): add node stage check.
|
2023-09-20 10:35:01 +08:00 |
|
dmchen
|
e36ff1282c
|
revert dependency
|
2023-09-19 13:42:02 +08:00 |
slzhou
|
c882f4ba08
|
fix: fix address sanitizer error
|
2023-09-19 11:31:20 +08:00 |
|
Haojun Liao
|
5a6e50d523
|
fix(stream): keep the status entry in hash table, instead entry index.
|
2023-09-19 10:33:58 +08:00 |
|
Haojun Liao
|
1ca06e960f
|
fix(stream): remove stream in buf.
|
2023-09-18 20:25:24 +08:00 |
|
dmchen
|
b473122dac
|
break dependency
|
2023-09-18 12:29:08 +08:00 |
|
dm chen
|
fda32dcc51
|
Merge branch 'main' into feat/TD-26127-audit-sql
|
2023-09-18 09:41:47 +08:00 |
|
Haojun Liao
|
3dfdda3283
|
fix(stream): fix error in decode stream task.
|
2023-09-17 18:07:26 +08:00 |
|
Haojun Liao
|
01144c58a7
|
fix(stream): fix stream task id error.
|
2023-09-17 01:19:59 +08:00 |
|
Haojun Liao
|
5f55f489d8
|
fix(stream): fix memory leak.
|
2023-09-14 22:59:11 +08:00 |
|
Haojun Liao
|
fce5be0eb4
|
fix(stream): fix dead lock.
|
2023-09-14 14:09:05 +08:00 |
|
Haojun Liao
|
9b70c0c457
|
fix:fix coverity issue and remove unnecessary files.
|
2023-09-14 09:06:10 +08:00 |
|
Haojun Liao
|
025a2a3b50
|
Merge pull request #22846 from taosdata/fix/3_liaohj
fix(tsdb): check the schema before merge rows in buffer
|
2023-09-12 11:43:27 +08:00 |
|
Haojun Liao
|
f602aa965f
|
fix(stream): fix coverity scan issues.
|
2023-09-12 09:16:18 +08:00 |
wangmm0220
|
842bb5742a
|
fix:[TS-3922]rollback because cases failed & avoid atomic_store_64 core if parameters not aligned by 8
|
2023-09-07 19:26:33 +08:00 |
|
dmchen
|
231ba12f70
|
feat/TD-26127
|
2023-09-06 11:00:24 +08:00 |
|
Haojun Liao
|
77eed06bcd
|
Merge branch '3.0' into fix/3_liaohj
|
2023-09-04 18:51:07 +08:00 |
|
Haojun Liao
|
aeea699c9c
|
Merge branch '3.0' into fix/3_liaohj
|
2023-09-04 15:53:39 +08:00 |
|
Haojun Liao
|
21dab8ceab
|
other: merge 3.0
|
2023-09-04 13:08:19 +08:00 |
|
Haojun Liao
|
d73de8ba1e
|
fix(stream): add null ptr check.
|
2023-09-02 16:44:21 +08:00 |
|
Haojun Liao
|
037a232bfa
|
refactor: do some internal refactor.
|
2023-09-01 17:05:36 +08:00 |
dapan1121
|
cc17848b78
|
fix: merge 3.0 to main
|
2023-09-01 13:24:47 +08:00 |
|
Haojun Liao
|
3765fbbba2
|
fix(stream): fix memory leak.
|
2023-09-01 09:59:56 +08:00 |
|
Haojun Liao
|
e8294ed8dc
|
fix(stream): fix bug in multi-replica vnode redistribute.
|
2023-09-01 03:10:12 +08:00 |
|
Haojun Liao
|
fecba5b097
|
fix(stream): check for meta
|
2023-08-31 20:54:02 +08:00 |
|
Haojun Liao
|
95da66e3e8
|
fix(stream): fix error.
|
2023-08-31 20:50:12 +08:00 |
|
dmchen
|
03de7ad5a6
|
stream name
|
2023-08-31 16:44:36 +08:00 |
yihaoDeng
|
05ca71d5de
|
stream change ver
|
2023-08-31 09:28:43 +08:00 |
|
Haojun Liao
|
c5b279f045
|
Merge remote-tracking branch 'origin/enh/triggerCheckPoint2' into enh/triggerCheckPoint2
|
2023-08-30 16:01:08 +08:00 |
|
Haojun Liao
|
24b1a050fc
|
other: merge 3.0
|
2023-08-30 16:00:14 +08:00 |
liuyao
|
0a72e576bd
|
op stream pause
pause data dispatch
opt stream pause
|
2023-08-30 14:53:49 +08:00 |
|
dmchen
|
1372cede48
|
init
|
2023-08-28 17:44:10 +08:00 |
dapan1121
|
778e50da79
|
Merge pull request #22592 from taosdata/fix/m23.0
Fix/m23.0
|
2023-08-28 17:35:35 +08:00 |
|
dapan1121
|
1f40da6fef
|
Merge remote-tracking branch 'origin/main' into 3.0
|
2023-08-28 09:28:55 +08:00 |
|
dmchen
|
06083e1eb9
|
init
|
2023-08-28 09:15:51 +08:00 |
|
Haojun Liao
|
7ceb8dc627
|
fix(stream): disable the follower to execute the stop/resume instruction.
|
2023-08-25 19:20:49 +08:00 |
|
liuyao
|
7d44b7e4cb
|
mem leak
|
2023-08-25 14:53:29 +08:00 |
|
liuyao
|
a72e6fd219
|
mem leak
|
2023-08-24 16:32:34 +08:00 |
|
Haojun Liao
|
809d3087ff
|
Merge remote-tracking branch 'origin/enh/triggerCheckPoint2' into enh/triggerCheckPoint2
# Conflicts:
# source/dnode/mnode/impl/src/mndStream.c
|
2023-08-23 17:53:50 +08:00 |
|
Haojun Liao
|
230d8c2d80
|
fix(stream): fix error in stream computing after vnode is transferred to other dnodes.
|
2023-08-23 17:50:44 +08:00 |