Haojun Liao
|
3236ef7bae
|
feat(stream): return the stream source task exec delay, and do some internal refactor.
|
2024-02-02 11:26:47 +08:00 |
wangmm0220
|
00e0da15a3
|
fix:[TD-28032]groupid = 0 & modify test case in sim
|
2024-01-12 17:37:22 +08:00 |
|
wangmm0220
|
02c7bdd4f0
|
fix:[TD-28032]fsdfasd
|
2024-01-10 14:57:16 +08:00 |
|
wangmm0220
|
b200e6807f
|
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-03 19:44:30 +08:00 |
|
wangmm0220
|
317f0c6a39
|
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-03 18:48:54 +08:00 |
|
wangmm0220
|
ab262550d1
|
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-03 10:37:05 +08:00 |
|
wangmm0220
|
9ba2f71487
|
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-03 10:16:43 +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 |
Cary Xu
|
1c2e9c18d5
|
Update tqSink.c
|
2023-11-10 22:01:28 +08:00 |
|
kailixu
|
c04fb6d543
|
enh: logic optimization
|
2023-11-10 17:23:17 +08:00 |
|
kailixu
|
bc44659826
|
fix: buffer overflow
|
2023-11-10 17:14:57 +08:00 |
|
kailixu
|
5fae10bc76
|
enh: error code when build delete req
|
2023-11-10 15:09:01 +08:00 |
|
kailixu
|
674e878ffa
|
enh: rsma support delete
|
2023-11-10 14:44:29 +08:00 |
|
Haojun Liao
|
8c2f6bab0e
|
fix(stream): exec scan-history in timer.
|
2023-11-07 16:40:03 +08:00 |
|
Haojun Liao
|
6e118c7963
|
fix(stream): fix memory leak.
|
2023-10-30 17:28:57 +08:00 |
|
Haojun Liao
|
15d217fc3e
|
fix(stream): fix memory leak.
|
2023-10-30 13:29:35 +08:00 |
|
Haojun Liao
|
2493c21ed3
|
fix(stream): fix the invalid write in sma
|
2023-10-27 09:58:52 +08:00 |
|
Haojun Liao
|
1ad2c3029a
|
refactor(stream): do some internal refactor.
|
2023-10-27 09:58:52 +08:00 |
|
Haojun Liao
|
3bcffcf1da
|
other: merge stream refactor from main.
|
2023-10-27 09:56:02 +08:00 |
|
Haojun Liao
|
579dd8e6b2
|
refactor(stream): do some internal refactor.
|
2023-10-27 09:54:56 +08:00 |
|
Haojun Liao
|
af2c0c95e9
|
refactor: do some internal refactor.
|
2023-10-09 20:10:22 +08:00 |
|
Haojun Liao
|
28008f8263
|
enh(stream): add more info for sink task.
|
2023-10-09 20:09:22 +08:00 |
|
Haojun Liao
|
a248f3d088
|
refactor: do some internal refactor.
|
2023-10-09 20:08:12 +08:00 |
|
Haojun Liao
|
0db357401d
|
fix(stream): add new status for meta.
|
2023-10-09 20:08:12 +08:00 |
|
Haojun Liao
|
6a98b11bef
|
fix(stream): fix invalid read and memory leak.
|
2023-10-09 20:08:11 +08:00 |
|
Haojun Liao
|
52763ca2a3
|
refactor: do some internal refactor.
|
2023-10-09 20:08:07 +08:00 |
|
Haojun Liao
|
012ddadf25
|
fix(stream): update logs.
|
2023-10-09 20:08:07 +08:00 |
|
Haojun Liao
|
ef9efc8a8e
|
refactor: do refactor the sink task.
|
2023-10-09 20:07:53 +08:00 |
|
Haojun Liao
|
1f45bd82d2
|
other: merge stream fix in main.
|
2023-10-09 20:07:01 +08:00 |
|
Haojun Liao
|
1a86ee6517
|
refactor: update the log level.
|
2023-10-09 20:06:06 +08:00 |
|
Haojun Liao
|
98ef566eb4
|
fix(stream): remove fill-history sink task.
|
2023-10-09 20:04:17 +08:00 |
|
Haojun Liao
|
e84eeee6b8
|
refactor: do some internal refactor.
|
2023-10-09 20:04:17 +08:00 |
|
Haojun Liao
|
e457d94ac6
|
refactor: do some internal refactor.
|
2023-09-12 18:09:02 +08:00 |
|
Haojun Liao
|
93159729f6
|
fix(stream):check error when vnode is closing.
|
2023-09-12 11:45:51 +08:00 |
|
Haojun Liao
|
5ab739ae46
|
fix(stream): fix memory leak.
|
2023-09-11 15:29:12 +08:00 |
|
Haojun Liao
|
50ef500f51
|
refactor(stream): do sink module refactor.
|
2023-09-11 10:09:31 +08:00 |
|
Haojun Liao
|
6f5c855a4b
|
fix(stream): fix msg lost bug.
|
2023-09-09 15:08:36 +08:00 |
|
Haojun Liao
|
b317c8ebff
|
fix(stream): disable merge submit blocks.
|
2023-09-08 12:46:15 +08:00 |
|
Haojun Liao
|
b240e91c91
|
enh(stream): add token bucket to limit the rate of sink operation.
|
2023-09-07 09:58:48 +08:00 |
|
Haojun Liao
|
2b84e0b02e
|
refactor: check if the put data into queue is success or failed.
|
2023-09-06 19:39:00 +08:00 |
|
Haojun Liao
|
8edf86b3bb
|
fix(stream): add some logs.
|
2023-09-06 19:08:09 +08:00 |
|
Haojun Liao
|
5ba6a68e7a
|
fix(stream): fix syntax error.
|
2023-09-06 19:00:39 +08:00 |
|
Haojun Liao
|
a82027f492
|
enh(stream): pack multi-datablock into one submit message.
|
2023-09-06 18:58:47 +08:00 |
|
Haojun Liao
|
926cc01cff
|
refactor: do some internal refactor.
|
2023-09-06 16:48:43 +08:00 |
|
Haojun Liao
|
b382cba58c
|
fix(stream): fix syntax error.
|
2023-09-06 14:37:58 +08:00 |
|
Haojun Liao
|
236b363996
|
fix(stream): fix syntax error.
|
2023-09-06 14:37:11 +08:00 |
|
Haojun Liao
|
8783ebcb02
|
enh(stream): add some logs and record the submit package performance.
|
2023-09-06 14:34:36 +08:00 |
|
Haojun Liao
|
c86eeb3938
|
fix(stream): add task status check when waiting for the table create.
|
2023-09-06 10:58:33 +08:00 |
|
Haojun Liao
|
dec4d69529
|
fix(stream): set correct user-define table name in sink table info cache.
|
2023-08-30 10:52:39 +08:00 |
|
Haojun Liao
|
8dadae5d3a
|
fix(stream): fix invalid read.
|
2023-08-29 18:24:32 +08:00 |
|
Haojun Liao
|
204fb97f68
|
fix(stream): fix error in snode, fix memory leaks, fix repeatly create bug in sink task.
|
2023-08-29 17:34:31 +08:00 |
liuyao
|
87c65f3b68
|
Merge remote-tracking branch 'origin/3.0' into enh/triggerCheckPoint2
|
2023-08-18 15:27:02 +08:00 |
|
liuyao
|
9d1e5a512d
|
add stream task id
|
2023-08-14 17:52:39 +08:00 |
|
liuyao
|
84f0dfd6d4
|
stream operator checkpoint
|
2023-07-10 11:07:08 +08:00 |
Haojun Liao
|
200575647c
|
Merge branch '3.0' into refact/fillhistory
|
2023-07-03 15:16:18 +08:00 |
dapan1121
|
3519e9170e
|
Merge remote-tracking branch 'origin/main' into 3.0
|
2023-06-29 11:13:45 +08:00 |
|
liuyao
|
71f4226e15
|
fix coverity san issues
|
2023-06-27 10:39:38 +08:00 |
|
Haojun Liao
|
53246ed6bb
|
other: merge other branch.
|
2023-06-09 09:41:10 +08:00 |
|
Haojun Liao
|
6726edae0c
|
fix(stream): add more logs.
|
2023-06-08 17:54:22 +08:00 |
|
liuyao
|
1e9c4d5fac
|
opt stream block dispatch
|
2023-06-07 10:45:27 +08:00 |
|
Haojun Liao
|
6a3c935b4a
|
fix(stream): fix error in fill history scan.
|
2023-06-07 09:15:55 +08:00 |
|
liuyao
|
27f791ac7f
|
reset ud table name
|
2023-06-02 11:05:39 +08:00 |
|
Haojun Liao
|
a3abe25539
|
refactor: do some internal refactor.
|
2023-05-31 19:03:37 +08:00 |
|
Haojun Liao
|
ac287572ef
|
fix: free table sink info
|
2023-05-15 00:03:53 +08:00 |
|
Haojun Liao
|
3d00f6ce54
|
refactor: do some internal refactor.
|
2023-05-14 22:08:17 +08:00 |
|
liuyao
|
8b7b804606
|
opt partition by tbname
|
2023-05-11 18:47:27 +08:00 |
|
Haojun Liao
|
9392c03b7f
|
fix(stream): add some logs.
|
2023-05-06 19:05:55 +08:00 |
|
Haojun Liao
|
da6212bab0
|
other: merge main.
|
2023-05-06 12:51:38 +08:00 |
|
Haojun Liao
|
09a04052ec
|
refactor: do some internal refactor.
|
2023-05-04 16:15:14 +08:00 |
|
liuyao
|
2984c5a758
|
merge main
|
2023-04-28 10:34:46 +08:00 |
|
Haojun Liao
|
db1d75bb48
|
refactor: do some internal refactor.
|
2023-04-27 09:28:20 +08:00 |
|
Haojun Liao
|
b57c813681
|
other: merge feature/3_liaohj
|
2023-04-14 10:36:54 +08:00 |
|
Haojun Liao
|
f8b672f09f
|
other: merge main.
|
2023-04-14 09:07:18 +08:00 |
yihaoDeng
|
b24b91886a
|
Merge branch 'dev3' into enh/rocksRevert
|
2023-04-11 10:59:00 +00:00 |
|
liuyao
|
524bb214e7
|
delete invalid code
|
2023-04-10 19:18:56 +08:00 |
|
Haojun Liao
|
f5b52749c2
|
refactor: do some internal refactor.
|
2023-04-09 01:39:09 +08:00 |
|
dapan1121
|
5b02af6a91
|
fix: merge main to 3.0
|
2023-03-22 16:08:16 +08:00 |
|
wangmm0220
|
0a54d00cd2
|
fix:converity scan defects
|
2023-03-17 14:54:27 +08:00 |
|
54liuyao
|
d5defa3def
|
fix:create same sub table
|
2023-03-15 11:10:55 +08:00 |
|
WANG MINGMING
|
5dfc9ed4d0
|
Merge branch '3.0' into fix/TD-22667-3.0
|
2023-02-28 09:52:34 +08:00 |
|
54liuyao
|
f2dfe5ab74
|
fix:create same sub table
|
2023-02-27 09:55:34 +08:00 |
|
Haojun Liao
|
80babb19f0
|
fix(query): fix syntax errors on centos.
|
2023-02-24 14:34:53 +08:00 |
|
Haojun Liao
|
993ae9e7e9
|
Merge branch '3.0' into fix/3_coverity
|
2023-02-24 14:34:01 +08:00 |
|
Haojun Liao
|
26ab5e011b
|
fix(query): fix syntax errors on centos.
|
2023-02-24 14:05:52 +08:00 |
|
Haojun Liao
|
22aa03307c
|
fix(query): fix syntax errors on centos.
|
2023-02-24 11:38:54 +08:00 |
|
54liuyao
|
e42d5ba3dc
|
fix:table name is null
|
2023-02-23 17:31:47 +08:00 |
|
wangmm0220
|
91d5df423f
|
fix:error by coverity scan
|
2023-02-22 15:48:39 +08:00 |
Xiaoyu Wang
|
d5cd2d36af
|
feat: compatible with older versions of wal
|
2023-02-17 15:55:55 +08:00 |
|
54liuyao
|
88970c88a9
|
fix:dispatch create sub table
|
2023-02-15 11:04:49 +08:00 |
|
54liuyao
|
c4414ec646
|
feat(stream):exists stable bug&ci
|
2023-02-01 17:27:04 +08:00 |
|
54liuyao
|
3ec1560faa
|
create stream and use existing super table
|
2023-01-13 10:26:49 +08:00 |
|
54liuyao
|
d5ade95b31
|
feat(stream):user define tag
|
2023-01-10 10:13:56 +08:00 |
|
Xiaoyu Wang
|
fdde287ca9
|
merge main
|
2023-01-04 11:43:20 +08:00 |
Liu Jicong
|
534561ffe1
|
merge 3.0
|
2023-01-03 18:18:39 +08:00 |
|
Liu Jicong
|
eacde27fdb
|
refactor: remove unused code
|
2023-01-03 11:24:11 +08:00 |
|
Liu Jicong
|
617d8d4013
|
fix mem leak
|
2023-01-03 11:18:48 +08:00 |
|
kailixu
|
8905a4839e
|
fix: tsma result submit for row/column update
|
2023-01-02 15:57:36 +08:00 |
|
Liu Jicong
|
3b24f882ed
|
fix mem leak
|
2022-12-26 11:34:05 +08:00 |
|
Liu Jicong
|
834495d62a
|
refact: adapt to new sml api
|
2022-12-26 10:14:59 +08:00 |
|
Xiaoyu Wang
|
0c269c317b
|
merge 3.0
|
2022-12-23 17:50:05 +08:00 |