kailixu
|
04c0c8b6cd
|
enh(grant): refine error code
|
2024-05-21 15:26:29 +08:00 |
Haojun Liao
|
d73fd5492a
|
fix(test): update test case.
|
2024-04-30 14:24:20 +08:00 |
|
Haojun Liao
|
4c27af9b13
|
refactor: do some internal refactor.
|
2024-04-30 13:25:39 +08:00 |
|
Haojun Liao
|
d3e676b084
|
fix(cos): fix syntax error.
|
2024-04-30 10:14:32 +08:00 |
|
Haojun Liao
|
9c39d11ea0
|
other: add some logs for drop streams.
|
2024-04-30 09:55:56 +08:00 |
|
Haojun Liao
|
9ba8e6bd34
|
refactor: add logs for drop streams.
|
2024-04-30 09:26:06 +08:00 |
|
Haojun Liao
|
3c5ca17737
|
Merge branch '3.0' into fix/3_liaohj
|
2024-04-28 13:57:16 +08:00 |
|
Haojun Liao
|
ed962186a1
|
enh(stream): add attrs for stream tasks.
|
2024-04-28 10:22:09 +08:00 |
|
Haojun Liao
|
b2d8260f14
|
refactor: do some internal refactor.
|
2024-04-28 10:05:22 +08:00 |
Haojun Liao
|
5f5595a6ab
|
Merge pull request #25517 from taosdata/fix/3_liaohj
fix(stream): add task node into update list if it is timeout for more than 100sec.
|
2024-04-26 17:00:23 +08:00 |
|
Haojun Liao
|
8b53f76691
|
fix(stream): discard the repeatly recv checkpoint-source msg.
|
2024-04-26 15:56:34 +08:00 |
54liuyao
|
3300bf04c1
|
opt bloom filter
|
2024-04-24 17:27:24 +08:00 |
|
kailixu
|
a0a7c05faf
|
fix: if not exists logic for topic/stream/table
|
2024-04-23 18:42:05 +08:00 |
|
Haojun Liao
|
4802cd1ddf
|
Merge branch '3.0' into fix/3_liaohj
|
2024-04-18 17:53:30 +08:00 |
|
Haojun Liao
|
ddf98ae0c2
|
refactor: do some internal refactor.
|
2024-04-17 18:04:02 +08:00 |
Yihao Deng
|
04e78d0ce7
|
Merge branch 'feat/3.0' into feat/compress_3.0
|
2024-04-17 03:23:02 +00:00 |
dapan1121
|
5936d3a1b0
|
Merge pull request #25300 from taosdata/draft/tsma_before_ci
feat: support tsma
|
2024-04-17 10:00:17 +08:00 |
|
Yihao Deng
|
6f9de676f0
|
Merge branch 'fix/compress_3.0' into feat/compress_3.0
|
2024-04-16 09:27:26 +00:00 |
|
Haojun Liao
|
5ae8b68b17
|
fix(stream): fix deadlock.
|
2024-04-16 15:37:51 +08:00 |
wangjiaming0909
|
6ce0616ffd
|
fix ci and TODOs
|
2024-04-16 14:25:34 +08:00 |
|
wangjiaming0909
|
a75c67efc8
|
rebase with stream sub table name no group id
|
2024-04-16 14:18:10 +08:00 |
|
Haojun Liao
|
810eb22eb2
|
fix(stream): generate the checkpoint id after checking the max checkpoint id from vnode.
|
2024-04-16 14:15:18 +08:00 |
|
wangjiaming0909
|
f77cd43d26
|
ins_tsmas
|
2024-04-16 14:13:10 +08:00 |
|
wangjiaming0909
|
6324d1293a
|
drop tsma
|
2024-04-16 14:13:10 +08:00 |
|
wangjiaming0909
|
8e2977d083
|
create tsma request
|
2024-04-16 14:13:10 +08:00 |
|
Haojun Liao
|
13bd296d58
|
Merge branch '3.0' into fix/3_liaohj
|
2024-04-15 18:53:48 +08:00 |
|
Haojun Liao
|
1ac192c069
|
fix(stream): keep the original tsdb scan version range.
|
2024-04-15 18:41:38 +08:00 |
|
Haojun Liao
|
665107ad3a
|
enh(stream): add more info in meta table.
|
2024-04-15 14:23:37 +08:00 |
yihaoDeng
|
4948bd690d
|
3.0 merge compress
|
2024-04-15 11:38:44 +08:00 |
|
54liuyao
|
1d42e927c6
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TS-4243-3.0
|
2024-04-11 15:35:42 +08:00 |
|
Haojun Liao
|
fabb986aa8
|
fix(stream): fix stack overflow, caused by print epset.
|
2024-04-10 19:54:33 +08:00 |
|
54liuyao
|
204c5acefe
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/ly-TS-4243-3.0
|
2024-04-02 09:10:52 +08:00 |
|
yihaoDeng
|
53ecfe511a
|
Merge branch '3.0' into feature/compressData
|
2024-04-01 08:04:16 +00:00 |
|
yihaoDeng
|
9e11fe45a9
|
fix ci error
|
2024-03-31 00:08:23 +00:00 |
wangmm0220
|
8e2a2414c0
|
fix:same subtable same partition by leads to same table name in stream
|
2024-03-28 13:48:46 +08:00 |
|
Haojun Liao
|
e776cde461
|
fix(stream):fix unrelease stream obj.
|
2024-03-27 09:02:21 +08:00 |
|
Haojun Liao
|
f3c306d582
|
fix(stream): add some comments.
|
2024-03-26 23:28:20 +08:00 |
|
Haojun Liao
|
3c7fe5fd01
|
fix(stream): check null ptr.
|
2024-03-26 23:27:38 +08:00 |
|
Haojun Liao
|
46280bfee9
|
fix(stream): add some comments.
|
2024-03-26 19:40:47 +08:00 |
|
Haojun Liao
|
530e0133b9
|
fix(stream): acquire the stream task in exec buffer if not in mnode store.
|
2024-03-26 19:39:58 +08:00 |
|
54liuyao
|
a02535c3ab
|
Merge branch 'feat/TS-4243-3.0' of https://github.com/taosdata/TDengine into feat/ly-TS-4243-3.0
|
2024-03-25 11:15:21 +08:00 |
|
54liuyao
|
a60f390cdc
|
stream primary key
|
2024-03-21 10:50:07 +08:00 |
|
Haojun Liao
|
a9ba534f48
|
fix(stream): adjust conflict level when creating stream.
|
2024-03-20 18:31:57 +08:00 |
|
Haojun Liao
|
7bdabc309b
|
Merge branch '3.0' into fix/3_liaohj
|
2024-03-18 14:16:15 +08:00 |
|
Haojun Liao
|
a576be6ae5
|
fix(stream): set the correct rows info for stream tasks when retreiving task info.
|
2024-03-15 15:19:20 +08:00 |
|
Haojun Liao
|
3aa2e24d78
|
Merge pull request #25006 from taosdata/fix/nullcheck
fix(stream): set the dest epset from mnode, and set the retry error
|
2024-03-05 19:46:41 +08:00 |
|
Haojun Liao
|
cdfbbc2985
|
fix(stream): set the dest epset from mnode, and set the retry error code for trans.
|
2024-03-05 13:28:34 +08:00 |
|
Haojun Liao
|
8791a163f8
|
other: merge 3.0
|
2024-02-29 22:31:52 +08:00 |
|
Haojun Liao
|
db92bf84d8
|
other: merge 3.0
|
2024-02-29 22:21:50 +08:00 |
|
Haojun Liao
|
dafac591f7
|
enh(stream): add rsp for req-checkpoint
|
2024-02-27 10:53:25 +08:00 |