Haojun Liao
|
cd1f0ea414
|
Merge pull request #22826 from taosdata/fix/3_liaohj
fix(stream): set the correct start version for the step 2 stage in fill history.
|
2023-09-11 21:43:58 +08:00 |
Haojun Liao
|
24524e1a8d
|
fix(stream): fix the invalid length of tag column name.
|
2023-09-11 19:10:54 +08:00 |
|
Haojun Liao
|
5ab739ae46
|
fix(stream): fix memory leak.
|
2023-09-11 15:29:12 +08:00 |
dapan1121
|
f831bf7d0f
|
Merge pull request #22810 from taosdata/fix/m/TD-26136
fix: coverity issues
|
2023-09-11 14:50:03 +08:00 |
|
Haojun Liao
|
45880f70d4
|
fix(stream): fix display error in logs.
|
2023-09-11 13:57:33 +08:00 |
|
Haojun Liao
|
3b79ab3266
|
fix(stream): reset the init ts.
|
2023-09-11 13:50:55 +08:00 |
|
Haojun Liao
|
c729fc989f
|
fix(stream): set the init start timestamp.
|
2023-09-11 13:49:43 +08:00 |
|
Haojun Liao
|
0980e021e5
|
fix(stream): set the correct start version for the step 2 stage in fill history.
|
2023-09-11 13:37:19 +08:00 |
|
Haojun Liao
|
50ef500f51
|
refactor(stream): do sink module refactor.
|
2023-09-11 10:09:31 +08:00 |
wade zhang
|
ddc8c93a9c
|
Merge pull request #22767 from taosdata/mark/tmq
fix:send delete subscribe info to vnode if drop consumer
|
2023-09-10 22:17:26 +08:00 |
|
wade zhang
|
635d405867
|
Merge pull request #22800 from taosdata/fix/TS-3922-main
fix:[TS-3922] make SStreamObj->->currentTick aligned by 8
|
2023-09-10 22:17:07 +08:00 |
|
Haojun Liao
|
372747cc23
|
Merge pull request #22818 from taosdata/fix/3_liaohj
fix(stream): fix error in fill history and check quit status of vnode.
|
2023-09-10 20:47:06 +08:00 |
|
Haojun Liao
|
a9321248a9
|
fix(stream): set the correct flag when there is one token existed.
|
2023-09-10 18:34:03 +08:00 |
|
Haojun Liao
|
10271aee26
|
fix(stream): fix syntax error in unit test.
|
2023-09-10 14:12:03 +08:00 |
|
Haojun Liao
|
4ffb4a5b1f
|
refactor: disable some logs.
|
2023-09-10 11:02:32 +08:00 |
|
Haojun Liao
|
85a5c45098
|
fix(stream): limit the already processed data.
|
2023-09-10 00:01:25 +08:00 |
|
Haojun Liao
|
9a30573b8b
|
fix(stream): disable scan wal when halt is set.
|
2023-09-09 16:12:08 +08:00 |
|
Haojun Liao
|
aa8909b267
|
other: add some logs.
|
2023-09-09 15:18:54 +08:00 |
|
Haojun Liao
|
6f5c855a4b
|
fix(stream): fix msg lost bug.
|
2023-09-09 15:08:36 +08:00 |
|
Haojun Liao
|
47fd144447
|
other: add some logs.
|
2023-09-09 11:19:51 +08:00 |
|
Haojun Liao
|
e4918e85eb
|
fix(stream): limit the sink rate
|
2023-09-09 00:22:22 +08:00 |
|
Haojun Liao
|
bf79c2c993
|
fix(stream): limit the sink rate
|
2023-09-09 00:11:13 +08:00 |
|
Haojun Liao
|
35b97cbd19
|
fix(stream): set correct token in bucket.
|
2023-09-08 23:50:41 +08:00 |
|
Haojun Liao
|
328377c25f
|
refactor: add some logs.
|
2023-09-08 23:04:39 +08:00 |
|
Haojun Liao
|
b317c8ebff
|
fix(stream): disable merge submit blocks.
|
2023-09-08 12:46:15 +08:00 |
wangjiaming0909
|
952d6e1492
|
fix: coverity issues
|
2023-09-08 10:26:37 +08:00 |
|
wade zhang
|
e4c83f29e3
|
Merge pull request #22802 from taosdata/fix/TD-25671-main
fix: next merger iter of tombs in loop of tsdbSnapWriteTombRecord
|
2023-09-08 09:05:28 +08:00 |
|
dapan1121
|
cd53ab870a
|
Merge pull request #22805 from taosdata/fix/TD-26160
fix: remove db dead lock issue
|
2023-09-08 08:30:40 +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 |
|
wade zhang
|
0499581c98
|
Merge pull request #22788 from taosdata/fix/xsren/TD-26163/basemain
stack overflow
|
2023-09-07 18:37:18 +08:00 |
dapan1121
|
6e5ee57fc1
|
fix: remove db dead lock issue
|
2023-09-07 18:01:06 +08:00 |
Benguang Zhao
|
2d5b18039d
|
fix: next merger iter of tombs in loop of tsdbSnapWriteTombRecord
|
2023-09-07 17:14:50 +08:00 |
|
dapan1121
|
615c619bba
|
Merge pull request #22782 from taosdata/fix/TS-3897
fix: fix diff not support unsigned type
|
2023-09-07 16:17:42 +08:00 |
|
wade zhang
|
3ea51721b9
|
Merge pull request #22797 from taosdata/fix/TD-25218-main
Fix/TD-25218: adjust the error code returned when db does not exist
|
2023-09-07 16:13:53 +08:00 |
|
wade zhang
|
d3f0c5ac3e
|
Merge pull request #22770 from taosdata/fix/TD-25445-main
fix/TD-25445: search memory in ttlMgrFindExpired
|
2023-09-07 16:13:32 +08:00 |
|
wangmm0220
|
c4898bffd8
|
fix:[TS-3922] make SStreamObj->->currentTick aligned by 8
|
2023-09-07 15:23:00 +08:00 |
Shungang Li
|
46af31539d
|
fix: adjust the error code returned when db does not exist
|
2023-09-07 14:52:34 +08:00 |
|
Haojun Liao
|
55ac835294
|
Merge branch 'main' into fix/3_liaohj
|
2023-09-07 11:47:25 +08:00 |
|
dapan1121
|
fdeb924d0d
|
Merge pull request #22715 from taosdata/fix/m/TD-26114
fix: desc fill missed one window
|
2023-09-07 11:36:30 +08:00 |
xsren
|
e5302b1677
|
stack overflow
|
2023-09-07 11:00:52 +08:00 |
|
Haojun Liao
|
dc821057e5
|
fix(stream): update the log.
|
2023-09-07 10:33:38 +08:00 |
|
dapan1121
|
afbb6edb59
|
Merge pull request #22755 from taosdata/fix/main/TD-26134
fix: fix coverity scan issue
|
2023-09-07 10:31:47 +08:00 |
|
dapan1121
|
e4f52bae5b
|
Merge pull request #22764 from taosdata/fix/TD-26132
fix: fix coverity issues
|
2023-09-07 10:09:30 +08:00 |
|
Haojun Liao
|
e407d7dc6b
|
fix(stream): update log.
|
2023-09-07 10:09:05 +08:00 |
|
Haojun Liao
|
956047a441
|
fix(stream): count down the token in bucket.
|
2023-09-07 10:02:13 +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 |
Ganlin Zhao
|
a762437100
|
fix issue
|
2023-09-07 09:54:06 +08:00 |
|
Ganlin Zhao
|
60d159731a
|
Revert "fix: fix diff not support unsigned type"
This reverts commit 7ccf959cdc44be7c5eaa0218f84db7699c126bbb.
|
2023-09-07 09:53:52 +08:00 |
|
Shungang Li
|
a6ba7e678f
|
fix: search memory in ttlMgrFindExpired
|
2023-09-07 09:33:26 +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 |