a3133b9f6d
feat(wal): log applied ver
2022-07-20 10:55:28 +08:00
bc1af6deaf
refactor(stream): batch optimization for submit msg
2022-07-19 15:52:08 +08:00
500553d581
refactor: add debug log
2022-07-18 11:41:56 +08:00
01a345a7c1
merge 3.0
2022-07-16 16:47:35 +08:00
bb58ec1e02
feat(tmq): support background heartbeat
2022-07-16 16:44:07 +08:00
219d966b25
fix(wal): read after rolling
2022-07-10 21:02:25 +08:00
a5e8ddbc56
refactor: adjust logs
2022-07-08 18:00:19 +08:00
43f1d41122
fix: compile error
2022-06-25 11:23:44 +08:00
23653fd843
enh: privilege for topic and stream
2022-06-25 11:22:34 +08:00
09ce47ae9f
refactor: rename auth to privilege
2022-06-25 10:27:27 +08:00
6f4f6c14fa
enh(tmq): add log
2022-06-11 14:02:48 +08:00
6fcee0e244
refactor(tsdb): tsdb reader open
2022-06-10 15:20:57 +08:00
deaa295fb5
Merge branch '3.0' into feature/3_liaohj
2022-06-08 20:44:01 +08:00
9eb8444373
fix tmq issue
2022-06-08 19:03:10 +08:00
238b2c1639
fix(tmq): status check
2022-06-08 18:10:38 +08:00
e1fd4a6640
feat(tmq): get_db api
2022-06-02 10:18:11 +08:00
1013b06107
refactor: make trans support global conflict
2022-05-31 19:24:26 +08:00
9057abeb39
Merge remote-tracking branch 'origin/3.0' into fix/mnode
2022-05-31 17:39:57 +08:00
04ef9e15e6
refactor: make trans support global conflict
2022-05-31 17:37:25 +08:00
d1259b3c82
fix(tmq): remove topic ref cnt
2022-05-30 22:50:59 +08:00
984b831563
fix(tmq): unref topic
2022-05-24 15:56:10 +08:00
a878b3edd5
fix: commit log should not be null
2022-05-23 21:17:04 +08:00
682a7cab17
fix: avoid memory leak
2022-05-21 16:35:24 +08:00
2f9c63ae3f
enh(tq): update tb uid when droping table
2022-05-19 15:37:30 +08:00
82b2ae4194
enh(tmq): set and show client id
2022-05-19 11:20:47 +08:00
9e71d03d37
enh(tmq): commit when consumer_close called
2022-05-18 15:31:05 +08:00
00a69a4d57
Merge remote-tracking branch 'origin/3.0' into fix/mnode
2022-05-17 19:41:53 +08:00
8ceae5854d
fix(tmq): fix memory leak
2022-05-17 17:01:07 +08:00
d7e895448d
fix: conflicts after refactor SRpcMsg
2022-05-17 16:32:23 +08:00
0623514ed1
Merge remote-tracking branch 'origin/3.0' into fix/mnode
2022-05-17 16:12:53 +08:00
44a9695460
enh(tmq): cascade drop
2022-05-17 04:09:25 +08:00
96b7f2696a
refactor: adjust SRpcMsg
2022-05-16 14:55:31 +08:00
15dd272154
enh(tmq): do not show closed consumer
2022-05-11 02:58:17 +08:00
ac460915d6
fix(tmq): show
2022-05-10 23:47:44 +08:00
661fbd2e46
enh(stream): improve topic show
2022-05-09 16:35:59 +08:00
3496381fcc
refactor: rebalance input
2022-04-29 21:01:13 +08:00
f78a31806c
enh(tmq): add rebalance global lock
2022-04-28 15:21:55 +08:00
108b9ee181
feat(stream): support perf schema
2022-04-28 13:36:43 +08:00
c790b4dfad
refacor(tmq): extract unassigned vg out of hash
2022-04-27 21:18:41 +08:00
e119a7ad48
fix
2022-04-27 17:27:36 +08:00
37a2977ad9
feat(tmq): consumer support recover
2022-04-27 17:15:02 +08:00
19ec7bcafc
enh: more info in perf schema
2022-04-27 15:16:57 +08:00
a5a10f7068
feat: tmq support show
2022-04-26 17:08:42 +08:00
f7a63661ac
fix
2022-04-20 22:08:04 +08:00
d75ab9b3ff
refactor
2022-04-20 21:36:55 +08:00
b7bf0fe10b
refactor(tmq): subscribe and rebalance process
2022-04-19 17:02:49 +08:00
bcbc8618d2
ehn(query): refactor show module in mnode.
2022-04-13 19:27:47 +08:00
208f639806
feature[query]:refactor show query processing in mnode.
2022-04-09 16:19:08 +08:00
798c3a9f82
add more log
2022-04-02 23:03:12 +08:00
9ebdee326f
fix txn
2022-04-01 18:13:46 +08:00
222db126bc
[TD-13758]<fix>: redefine memory api.
2022-03-26 00:29:53 +08:00
ba12601dff
Merge remote-tracking branch 'origin/3.0' into feature/shm
2022-03-16 14:48:49 +08:00
3c6c518470
[TD-13063]<feature>: 3.0 on windows ( #10765 )
...
* [TD-13063]<feature>: 3.0 on Windows
* add pthread in contrib
* fix linux compile
* fix osSemaphore
* add gnu regex for Windows
* fix compile error for Windows
* support arm platform
* port more OS files
* fix for Windows compile
* port more files
* fix macOS on x86_64
* port osFile
* port osSemaphone.h
* port osSocket.c
* port tconfig.c
* port ttimer.c
* add couple files
* merge with 3.0
2022-03-16 11:37:31 +08:00
332da70335
rename msg
2022-03-15 20:53:29 +08:00
ae4835dbc5
shm
2022-03-11 11:53:52 +08:00
d89f396dc7
serialize stb msg
2022-02-15 18:17:18 +08:00
f51295a23c
seperate rebalance msg from set conn msg
2022-02-12 11:28:22 +08:00
f0d7d1b323
mq rebalance
2022-02-11 18:09:25 +08:00
42da4f6fdd
rewrite rebalance
2022-02-11 16:24:38 +08:00
432f8bfd6b
rewrite rebalance
2022-02-10 11:22:50 +08:00
573aad5cc1
fix uninitialized
2022-02-03 19:47:27 +08:00
8f24333d7d
fix mem leak
2022-01-28 19:10:18 +08:00
ca84e47a97
fix query crash
2022-01-25 15:17:02 +08:00
d410ef1ca2
fix plan convert error
2022-01-24 18:21:25 +08:00
00ccbb4a3a
add subscribe for sdb
2022-01-19 16:28:13 +08:00
ddf7dcc94f
fix mem leak
2022-01-18 16:02:12 +08:00
a326b29021
minor changes
2022-01-10 04:44:11 -08:00
8a437a89dc
add heartbeat framework
2022-01-06 18:17:08 +08:00
b0d935ba7d
merge from 3.0
2022-01-06 10:56:25 +08:00
df554c03fc
handle merge conflict
2022-01-06 10:44:34 +08:00
0ba5427a9b
handle subscribe
2022-01-06 10:28:34 +08:00
0a83ecac81
add sub structure
2022-01-04 10:40:34 +08:00
d3927b54c0
Improve the error handling of mnode
2021-12-30 22:22:50 -08:00
335de53594
add mndconsumer
2021-12-29 17:53:43 +08:00
Liu Jicong
Shengliang Guan
dapan1121
dapan1121
Haojun Liao
afwerar
Shuduo Sang