Liu Jicong
a696ed583a
test(stream): _wstartts should be reverse quoted
2022-05-18 21:23:06 +08:00
Shengliang Guan
00a69a4d57
Merge remote-tracking branch 'origin/3.0' into fix/mnode
2022-05-17 19:41:53 +08:00
Liu Jicong
8ceae5854d
fix(tmq): fix memory leak
2022-05-17 17:01:07 +08:00
Shengliang Guan
d7e895448d
fix: conflicts after refactor SRpcMsg
2022-05-17 16:32:23 +08:00
Shengliang Guan
0623514ed1
Merge remote-tracking branch 'origin/3.0' into fix/mnode
2022-05-17 16:12:53 +08:00
Liu Jicong
2aec989bd7
enh(tmq): add drop msg to vnode
2022-05-17 05:13:27 +08:00
Liu Jicong
a2ee1c0bf6
enh(tmq): add drop msg to vnode
2022-05-17 04:29:17 +08:00
Liu Jicong
44a9695460
enh(tmq): cascade drop
2022-05-17 04:09:25 +08:00
Shengliang Guan
96b7f2696a
refactor: adjust SRpcMsg
2022-05-16 14:55:31 +08:00
Liu Jicong
714dd4f497
enh(tmq): only read committed log
2022-05-11 14:42:20 +08:00
Liu Jicong
ac460915d6
fix(tmq): show
2022-05-10 23:47:44 +08:00
Liu Jicong
52e1fcbff7
feat(tmq): show subcription
2022-05-09 18:09:55 +08:00
Liu Jicong
3496381fcc
refactor: rebalance input
2022-04-29 21:01:13 +08:00
Liu Jicong
de939d589f
fix: memory error
2022-04-29 20:11:58 +08:00
Liu Jicong
5c36e4e519
fix: subscrption api
2022-04-29 14:34:30 +08:00
Liu Jicong
f78a31806c
enh(tmq): add rebalance global lock
2022-04-28 15:21:55 +08:00
Liu Jicong
108b9ee181
feat(stream): support perf schema
2022-04-28 13:36:43 +08:00
Liu Jicong
c790b4dfad
refacor(tmq): extract unassigned vg out of hash
2022-04-27 21:18:41 +08:00
Liu Jicong
575f64197d
enh(wal): skip read for specific msg
2022-04-24 16:51:32 +08:00
Liu Jicong
cb1318a76b
fix flag init
2022-04-21 17:08:11 +08:00
Liu Jicong
2dcb014511
feat(tmq): add db subscribe
2022-04-21 16:37:55 +08:00
Liu Jicong
ce6459a9f8
fix(tmq): rebalance
2022-04-21 01:47:29 +08:00
Liu Jicong
d75ab9b3ff
refactor
2022-04-20 21:36:55 +08:00
Liu Jicong
b7bf0fe10b
refactor(tmq): subscribe and rebalance process
2022-04-19 17:02:49 +08:00
Liu Jicong
69cb4b5c99
refactor(tmq): persist ast in topic
2022-04-14 20:34:42 +08:00
Liu Jicong
0fe0d6fc77
fix: fix tmq result parse
2022-04-13 20:37:51 +08:00
Liu Jicong
6df2fae1a2
fix compile
2022-04-08 15:26:02 +08:00
Liu Jicong
74eee69a65
fix
2022-04-07 19:57:49 +08:00
Liu Jicong
d5fb11d239
add unsubscribe
2022-04-07 18:20:54 +08:00
Liu Jicong
a60185adc8
add more log
2022-04-07 14:11:16 +08:00
Liu Jicong
798c3a9f82
add more log
2022-04-02 23:03:12 +08:00
Liu Jicong
8e2d121b3a
temp
2022-04-02 19:59:25 +08:00
Liu Jicong
adf8bd5e82
add log
2022-04-01 21:30:06 +08:00
Liu Jicong
9ebdee326f
fix txn
2022-04-01 18:13:46 +08:00
Liu Jicong
e916f83fd7
temp
2022-04-01 09:57:55 +08:00
Liu Jicong
4fd6f59092
stream set multi input
2022-03-29 15:24:25 +08:00
afwerar
222db126bc
[TD-13758]<fix>: redefine memory api.
2022-03-26 00:29:53 +08:00
Liu Jicong
f72930eef6
Merge pull request #10880 from taosdata/feature/tq
...
fix memory error
2022-03-21 23:49:10 +08:00
Liu Jicong
b08c3120bf
fix memory error
2022-03-21 23:36:21 +08:00
Liu Jicong
a36cfba9b9
Merge pull request #10879 from taosdata/feature/tq
...
Feature/tq
2022-03-21 21:54:30 +08:00
Liu Jicong
8a20b2fe50
fix memory error
2022-03-21 21:42:37 +08:00
Shengliang Guan
220fdfabe2
refact dnode queue
2022-03-21 19:08:25 +08:00
Shengliang Guan
5832b6772c
shm
2022-03-16 21:18:54 +08:00
Shengliang Guan
ba12601dff
Merge remote-tracking branch 'origin/3.0' into feature/shm
2022-03-16 14:48:49 +08:00
Shuduo Sang
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
Shengliang Guan
332da70335
rename msg
2022-03-15 20:53:29 +08:00
Shengliang Guan
8a0ab2615e
Merge remote-tracking branch 'origin/3.0' into feature/shm
2022-03-12 11:52:18 +08:00
Shengliang Guan
ae4835dbc5
shm
2022-03-11 11:53:52 +08:00
Xiaoyu Wang
066c39d571
TD-13747 merge 3.0
2022-03-09 21:35:24 -05:00
Liu Jicong
255d795442
add tq push
2022-03-08 17:22:21 +08:00