3f46a9bbc9
feat:add parameters for consumer & add offset rows for subscription
2023-06-08 18:14:02 +08:00
56782a5d41
fix:open task case & modify mqRebVgReq encode/decode style
2023-06-01 18:29:16 +08:00
30104f300c
enh: refactor func names of mndTransPerformFinishedStage and mndTrancCheckConflict
2023-05-25 15:44:26 +08:00
1f973123c4
Merge pull request #21177 from taosdata/fix/TD-23972
...
fix:[TD-23972] push subscribe msg to vnode even though consumer not c…
2023-05-08 20:29:31 +08:00
279fe0803f
fix:[TD-23972] push subscribe msg to vnode even though consumer not change
2023-05-06 18:35:24 +08:00
55eddbfb5e
fix:[TD-23972] push subscribe msg to vnode even though consumer not change
2023-05-06 10:54:05 +08:00
25f451ba81
fix(tmq): fix result data block info.
2023-05-04 23:34:35 +08:00
a53c181b98
fix(tmq): remove invalid assert
2023-05-04 10:04:44 +08:00
5b25920fec
refactor: do some internal refactor.
2023-05-02 23:19:32 +08:00
1771a54256
fix:rebalance not only one in once timer
2023-04-17 19:59:11 +08:00
f65cd36e80
opti:the logic of mndDoRebalance for clear
2023-04-16 00:54:11 +08:00
584cdf041c
opti:the logic of mndDoRebalance for clear
2023-04-14 18:34:41 +08:00
02ec67ad9e
Merge pull request #20882 from taosdata/fix/TS-3081
...
fix:open test cases for tmq & add log if rebalance error
2023-04-14 17:56:58 +08:00
bb22d9ee5e
fix:open test cases for tmq & add log if rebalance error
2023-04-12 10:56:19 +08:00
e9d7a099cc
merge main
2023-04-04 14:50:58 +08:00
94c6af39da
fix(tmq): fix the invalid free
2023-03-29 10:46:44 +08:00
ceb160c23b
fix(query): fix memory leak.
2023-03-28 23:14:11 +08:00
b444e8db1a
others: merge main.
2023-03-28 19:42:07 +08:00
5b02af6a91
fix: merge main to 3.0
2023-03-22 16:08:16 +08:00
a4e378e138
refactor: update some log.
2023-03-10 09:30:59 +08:00
fc39a330b4
fix:wrong uasge of taosArrayGet
2023-03-06 23:30:25 +08:00
77f86c6729
fix:wrong uasge of taosArrayGet
2023-03-06 23:24:30 +08:00
60cdbe37d3
refactor: do some internal refactor.
2023-03-06 22:25:34 +08:00
1b93f980e8
refactor: do some internal refactor.
2023-03-06 21:33:31 +08:00
e92bfa558d
fix(query): allow only one trans to be execute for each balance, and do some other refactor.
2023-03-06 21:16:30 +08:00
da550029d8
fix(tmq): fix memory error and adjust some logs.
2023-03-06 11:52:52 +08:00
22a85734c6
fix(mq): add more chek for balance couner to avoid the negative value emerges.
2023-03-05 13:23:50 +08:00
53a0ff0be3
refactor: add some logs.
2023-03-04 16:19:45 +08:00
8ffc397cf2
fix: minor changes
2023-03-03 10:35:13 +08:00
b46098793d
refactor: do some internal refactor and add some logs for tmq.
2023-02-26 12:16:45 +08:00
24c38d30e3
Merge remote-tracking branch 'origin/feature/3_liaohj' into feature/3_liaohj
2023-02-23 14:10:25 +08:00
f00b7b3af0
refactor: do some internal refactor.
2023-02-23 14:09:56 +08:00
4432ae51e6
Merge branch 'main' into fix/liaohj
2023-02-23 09:04:32 +08:00
9a5b7ce220
refactor: do some internal refactor.
2023-02-21 15:32:17 +08:00
8d187efc18
refactor:do some internal refactor.
2023-02-20 10:04:08 +08:00
59c72beb8d
fix(query): set the correct rows in data block.
2023-02-18 19:47:18 +08:00
4853522e11
fix(query): set the correct rows in data block.
2023-02-18 19:46:37 +08:00
ad8c73645b
fix: update epset on dnode info changed
2023-01-13 15:26:24 +08:00
9df158e1d9
fix: update assert info
2023-01-03 20:12:25 +08:00
e4ab8f986b
remove assert
2023-01-03 17:06:43 +08:00
9a10242f7d
enh: remove assert from mnode consumer
2023-01-03 16:16:58 +08:00
fc21140e03
enh: remove assert from mnode
2023-01-03 15:33:50 +08:00
cb5ec76cce
enh: check conflict before create trans
2022-12-23 13:58:39 +08:00
a366696478
Merge pull request #18596 from taosdata/feature/stream
...
refactor(stream): distributed checkpoint
2022-12-02 07:51:10 +08:00
3424b184d3
refactor(stream): distributed checkpoint
2022-12-02 03:48:45 +08:00
2d48563959
fix: crash if failed to decode sdb row
2022-12-01 16:04:39 +08:00
729b35b6e5
fix: memory leak while subscribe
2022-11-25 17:22:12 +08:00
e2005cfa86
fix(stream): skip check update for scalar
2022-11-16 18:48:08 +08:00
76cd3122d1
fix: memory leak
2022-11-15 14:28:20 +08:00
efde22f081
fix: memory leak
2022-11-15 11:59:29 +08:00
d6c389a6cc
refactor(tmq): add debug log
2022-11-14 10:46:05 +08:00
2fbc8e6306
refactor(stream): stream deploy and state transfer
2022-11-03 13:22:23 +08:00
2e640c38a2
refactor: stream and tmq message
2022-10-31 18:37:28 +08:00
dcf2c980c5
refactor(mnode): remove unused code
2022-10-27 15:32:20 +08:00
2a3448552e
test(wal): rollback multiple file
2022-10-26 18:03:25 +08:00
1c26f1b53e
fix(wal): reference
2022-10-21 16:13:55 +08:00
3b0968d7f9
enh: enable the -Wformat=2 compiler option
2022-10-19 09:24:15 +08:00
b1594a6857
fix coverity scan
2022-10-10 11:44:17 +08:00
c6317e67f0
fix: coverity issues
2022-09-30 11:26:26 +08:00
3810b5d4fa
fix: add more info log for mnode
2022-09-23 15:42:36 +08:00
43ef21f67b
enh: add oper name to show transaction
2022-09-22 16:19:33 +08:00
273adb9895
fix memory leak
2022-09-16 16:17:02 +08:00
c7f986a656
refactor(tmq): add error code
2022-09-14 17:11:50 +08:00
8b3489760c
feat(tmq): support taosx
2022-08-30 11:12:20 +08:00
27e2ba79c0
Merge branch '3.0' into feature/stream
2022-08-17 01:11:18 +08:00
58ea5563a5
fix(tmq): rebalance
2022-08-16 19:46:42 +08:00
365dc43fec
enh(tmq): add log
2022-08-10 19:03:04 +08:00
d4abe20eeb
fix: can't drop db since transaction conflict
2022-07-25 18:21:13 +08:00
81d8d2b937
feat(stream): add version in stream block
2022-07-21 17:27:44 +08:00
053786e6b4
fix(stream): data exec
2022-07-18 15:50:36 +08:00
c53a84b733
Merge remote-tracking branch 'origin/3.0' into fix/valgrind
2022-07-09 20:13:26 +08:00
a5e8ddbc56
refactor: adjust logs
2022-07-08 18:00:19 +08:00
3cd5a35054
refactor(stream): internal refactor
2022-07-08 17:48:34 +08:00
3f6ce2da73
feat(tmq): support topic with meta
2022-06-21 15:18:09 +08:00
5ae355077c
enh(mnode): transaction conflict supports two db
2022-06-17 11:11:29 +08:00
6fcee0e244
refactor(tsdb): tsdb reader open
2022-06-10 15:20:57 +08:00
980e289cdf
refactor: add alter-confirm while alter db
2022-06-05 14:59:53 +08:00
0bade86534
Merge pull request #13410 from taosdata/fix/mnode
...
enh: adjust vnode replica and some logs
2022-06-02 17:06:10 +08:00
27c1687a05
refactor: adjust some logs
2022-06-02 14:30:26 +08:00
f2048b00cb
fix(tmq): subscribe stb
2022-06-02 11:01:05 +08:00
e1fd4a6640
feat(tmq): get_db api
2022-06-02 10:18:11 +08:00
70e6e15920
Merge branch 'fix/mnode' into fix/tsim
2022-06-01 09:41:54 +08:00
77757f3ef9
feat(tmq): support drop cgroup
2022-05-31 19:52:40 +08:00
1013b06107
refactor: make trans support global conflict
2022-05-31 19:24:26 +08:00
ce62042a47
Merge pull request #13304 from taosdata/feature/topic_grammar
...
feat(tmq): create topic new grammar
2022-05-31 18:30:21 +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
691cc93ed2
Merge pull request #13311 from taosdata/fix/mnode
...
refactor: make trans support multi steps
2022-05-31 17:28:39 +08:00
451d19f986
feat(tmq): create topic new grammar
2022-05-31 16:20:40 +08:00
0e3f6be61c
Merge pull request #13254 from taosdata/feature/tq
...
fix(tmq): remove topic ref cnt
2022-05-30 23:06:15 +08:00
d1259b3c82
fix(tmq): remove topic ref cnt
2022-05-30 22:50:59 +08:00
53def5b77b
refactor: make trans support multi steps
2022-05-30 20:38:46 +08:00
536ea7b9da
refactor: rename trans types
2022-05-30 09:47:16 +08:00
1aa97bc117
fix(tmq): update tq for auto create table
2022-05-28 19:48:17 +08:00
d6094a4368
feat(tmq): drop cgroup
2022-05-27 10:24:40 +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
a696ed583a
test(stream): _wstartts should be reverse quoted
2022-05-18 21:23:06 +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
2aec989bd7
enh(tmq): add drop msg to vnode
2022-05-17 05:13:27 +08:00
a2ee1c0bf6
enh(tmq): add drop msg to vnode
2022-05-17 04:29:17 +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
714dd4f497
enh(tmq): only read committed log
2022-05-11 14:42:20 +08:00
ac460915d6
fix(tmq): show
2022-05-10 23:47:44 +08:00
52e1fcbff7
feat(tmq): show subcription
2022-05-09 18:09:55 +08:00
3496381fcc
refactor: rebalance input
2022-04-29 21:01:13 +08:00
de939d589f
fix: memory error
2022-04-29 20:11:58 +08:00
5c36e4e519
fix: subscrption api
2022-04-29 14:34:30 +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
575f64197d
enh(wal): skip read for specific msg
2022-04-24 16:51:32 +08:00
cb1318a76b
fix flag init
2022-04-21 17:08:11 +08:00
2dcb014511
feat(tmq): add db subscribe
2022-04-21 16:37:55 +08:00
ce6459a9f8
fix(tmq): rebalance
2022-04-21 01:47:29 +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
69cb4b5c99
refactor(tmq): persist ast in topic
2022-04-14 20:34:42 +08:00
0fe0d6fc77
fix: fix tmq result parse
2022-04-13 20:37:51 +08:00
6df2fae1a2
fix compile
2022-04-08 15:26:02 +08:00
74eee69a65
fix
2022-04-07 19:57:49 +08:00
d5fb11d239
add unsubscribe
2022-04-07 18:20:54 +08:00
a60185adc8
add more log
2022-04-07 14:11:16 +08:00
798c3a9f82
add more log
2022-04-02 23:03:12 +08:00
8e2d121b3a
temp
2022-04-02 19:59:25 +08:00
adf8bd5e82
add log
2022-04-01 21:30:06 +08:00
9ebdee326f
fix txn
2022-04-01 18:13:46 +08:00
e916f83fd7
temp
2022-04-01 09:57:55 +08:00
4fd6f59092
stream set multi input
2022-03-29 15:24:25 +08:00
222db126bc
[TD-13758]<fix>: redefine memory api.
2022-03-26 00:29:53 +08:00
f72930eef6
Merge pull request #10880 from taosdata/feature/tq
...
fix memory error
2022-03-21 23:49:10 +08:00
b08c3120bf
fix memory error
2022-03-21 23:36:21 +08:00
a36cfba9b9
Merge pull request #10879 from taosdata/feature/tq
...
Feature/tq
2022-03-21 21:54:30 +08:00
8a20b2fe50
fix memory error
2022-03-21 21:42:37 +08:00
220fdfabe2
refact dnode queue
2022-03-21 19:08:25 +08:00
5832b6772c
shm
2022-03-16 21:18:54 +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
8a0ab2615e
Merge remote-tracking branch 'origin/3.0' into feature/shm
2022-03-12 11:52:18 +08:00
ae4835dbc5
shm
2022-03-11 11:53:52 +08:00
066c39d571
TD-13747 merge 3.0
2022-03-09 21:35:24 -05:00
255d795442
add tq push
2022-03-08 17:22:21 +08:00
6cc87452cf
Merge remote-tracking branch 'origin/3.0' into feature/3.0_query_integrate_wxy
2022-03-07 21:56:17 -05:00
4d9cc5997a
subscribe key used stack mem
2022-03-07 17:56:19 +08:00
402a5e3b61
add scheduler
2022-03-07 16:30:28 +08:00
wangmm0220
Benguang Zhao
dapan1121
Haojun Liao
Haojun Liao
Xiaoyu Wang
dapan1121
Shengliang Guan
Liu Jicong
afwerar
Shuduo Sang