wangmm0220
|
4f168b4b2d
|
fix:tmqVnodeSplit-column.py failed in arm64 because of rebalance after unsubscribe while split vnode
|
2023-11-29 17:22:43 +08:00 |
wangmm0220
|
ce2fc8b319
|
fix:memory leak
|
2023-09-21 10:05:52 +08:00 |
wangmm0220
|
f9c5aa01af
|
fix:enable split if there are topics & fix memory leak
|
2023-09-21 09:20:34 +08:00 |
wangmm0220
|
d3f54e678f
|
feat:support vnode split in tmq
|
2023-09-20 18:27:43 +08:00 |
wangmm0220
|
2881a2504c
|
fix:conflicts from 3.0
|
2023-09-19 18:39:40 +08:00 |
wangmm0220
|
edb42aa2aa
|
fix:move from main to 3.0
|
2023-09-19 11:51:52 +08:00 |
wangmm0220
|
4b74135350
|
fix:vnode tranform support in tmq
|
2023-09-18 19:47:28 +08:00 |
wangmm0220
|
49a193b328
|
fix:send delete subscribe info to vnode if drop consumer
|
2023-09-18 14:46:39 +08:00 |
dapan1121
|
f6321d0c4f
|
Merge remote-tracking branch 'origin/main' into fix/m23.1
|
2023-08-30 11:03:33 +08:00 |
wangmm0220
|
047707fa17
|
fix:error in privilege
|
2023-08-25 17:56:17 +08:00 |
wangmm0220
|
49216ffa54
|
fix:transaction in tmq
|
2023-08-24 16:32:15 +08:00 |
wangmm0220
|
8f3956cc67
|
fix:[TD-258900]modify tmq trans conflict to db level
|
2023-08-24 09:25:26 +08:00 |
Haojun Liao
|
9e3733a02c
|
Merge pull request #22358 from taosdata/feat/TD-24559
feat:[TD-24559]support geomety type in schemaless
|
2023-08-14 22:06:41 +08:00 |
wangmm0220
|
25e32bbf7c
|
fix:offset error in tmq & add test cases
|
2023-08-11 14:25:12 +08:00 |
wangmm0220
|
1f5532fd67
|
fix:offset error in tmq & add test cases
|
2023-08-09 19:41:22 +08:00 |
wangmm0220
|
864d07e1bc
|
feat:[TD-24559]support geomety type in schemaless
|
2023-08-07 19:39:06 +08:00 |
wangmm0220
|
cddf27e8b4
|
fix:add committed & seek process logic
|
2023-07-31 18:48:50 +08:00 |
wangmm0220
|
6179618b17
|
fix:add committed & seek process logic
|
2023-07-31 17:56:04 +08:00 |
wangmm0220
|
2d41a42976
|
Merge branch 'main' of https://github.com/taosdata/TDengine into fix/TS-3728
|
2023-07-27 15:31:16 +08:00 |
wangmm0220
|
be4e47e9a7
|
fix:add macro ASSERT_NOT_CORE to control ASSERT not core in release version
|
2023-07-25 16:15:33 +08:00 |
wangmm0220
|
9628a9f74e
|
fix:open info log in tmq & ignore wal apply ver when read wal
|
2023-07-24 15:53:02 +08:00 |
wangmm0220
|
da9e30434a
|
fix:add sdbFetchCancel to release hash node
|
2023-07-17 20:21:23 +08:00 |
wangmm0220
|
cb62d4cb97
|
fix:set firset version to reqOffset of response
|
2023-07-11 14:49:53 +08:00 |
wangmm0220
|
34a62c3f38
|
fix:vginfo assigment not in same time,we should get vginfo by vg,not all vg
|
2023-07-05 22:55:41 +08:00 |
yihaoDeng
|
b377fcffad
|
fix:show subscriptions error
|
2023-06-29 16:04:02 +08:00 |
yihaoDeng
|
0b3fbfd87f
|
fix:compile error
|
2023-06-29 14:40:32 +08:00 |
dapan1121
|
c8435de64a
|
Merge branch '3.0' into fix/m23.0
|
2023-06-29 14:03:56 +08:00 |
dapan1121
|
5ee1fbee7e
|
fix: code merge issue
|
2023-06-29 14:01:19 +08:00 |
dapan1121
|
bb1e24dda4
|
Merge remote-tracking branch 'origin/main' into fix/m23.0
|
2023-06-29 13:59:56 +08:00 |
dapan1121
|
edf5b8c936
|
fix: code merge issue
|
2023-06-29 13:59:39 +08:00 |
dapan1121
|
3519e9170e
|
Merge remote-tracking branch 'origin/main' into 3.0
|
2023-06-29 11:13:45 +08:00 |
wangmm0220
|
64d8d63f3d
|
fix:error in limit for tmq group
|
2023-06-29 10:47:55 +08:00 |
wangmm0220
|
4ead47bcbd
|
fix:add rows to pSub if rebalance
|
2023-06-28 16:43:30 +08:00 |
wangmm0220
|
865a3b2509
|
fix:add rows to pSub if rebalance
|
2023-06-28 16:37:57 +08:00 |
wangmm0220
|
ce0b71c634
|
fix:add rows to pSub if rebalance
|
2023-06-28 15:57:30 +08:00 |
wangmm0220
|
4a17f4b9f5
|
fix:add rows to pSub if rebalance
|
2023-06-28 14:57:31 +08:00 |
wangmm0220
|
4b95ea9cad
|
fix:clear consumer if normal close
|
2023-06-27 17:11:20 +08:00 |
wangmm0220
|
779e35b679
|
fix:drop consumer wher drop topic or group
|
2023-06-16 13:52:08 +08:00 |
wangmm0220
|
e019ed2cc3
|
fix:conflict
|
2023-06-15 18:50:44 +08:00 |
wangmm0220
|
5de4600739
|
fix:remove lost_reb status
|
2023-06-15 18:48:45 +08:00 |
yihaoDeng
|
a17a8cc192
|
fix:null pointer error
|
2023-06-15 16:35:53 +08:00 |
wangmm0220
|
a7a518aaed
|
opti:tmq logic
|
2023-06-15 15:44:52 +08:00 |
wangmm0220
|
22776e60d5
|
fix:control memory size if consumer group is too much
|
2023-06-15 14:51:04 +08:00 |
wangmm0220
|
d8d6b6dd21
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into feature/TD-24749
|
2023-06-13 15:15:05 +08:00 |
Haojun Liao
|
933d08b489
|
Merge pull request #21690 from taosdata/feature/TS-3495
feat:add parameters for consumer & add offset rows for subscription
|
2023-06-13 14:59:15 +08:00 |
wangmm0220
|
fb123d8761
|
fix:conflict from 3.0
|
2023-06-13 09:47:08 +08:00 |
wangmm0220
|
fb59ec4591
|
feat:move plan msg from vginfo to subscription info
|
2023-06-13 09:32:54 +08:00 |
wangmm0220
|
a723fc37c3
|
fix:modify offset description to string
|
2023-06-12 17:18:06 +08:00 |
wangmm0220
|
fe155898fe
|
fix:modify offset description to string
|
2023-06-12 16:34:53 +08:00 |
Benguang Zhao
|
3689b41f3a
|
Merge branch '3.0' into FIX/TD-24182-3.0
|
2023-06-12 09:39:49 +08:00 |