Minglei Jin
|
dca985214c
|
cache/last: new api: merge last with cid
|
2023-05-06 18:44:15 +08:00 |
wangmm0220
|
279fe0803f
|
fix:[TD-23972] push subscribe msg to vnode even though consumer not change
|
2023-05-06 18:35:24 +08:00 |
|
wangmm0220
|
ee32620808
|
fix:[TS-3347]set ver to first version if version stored is smaller than first version in wal when subscribe db
|
2023-05-06 16:22:30 +08:00 |
|
Minglei Jin
|
596bee8028
|
Merge branch '3.0' into fix/TD-23623
|
2023-05-06 16:07:26 +08:00 |
Haojun Liao
|
f1a638c196
|
refactor: do some internal refactor.
|
2023-05-06 13:36:42 +08:00 |
|
Haojun Liao
|
6b305bf745
|
refactor: do some internal refactor.
|
2023-05-06 13:35:18 +08:00 |
|
Haojun Liao
|
7dfa4c2105
|
fix(query): fix syntax error.
|
2023-05-06 13:13:28 +08:00 |
|
Haojun Liao
|
da6212bab0
|
other: merge main.
|
2023-05-06 12:51:38 +08:00 |
|
wangmm0220
|
446097434e
|
fix:[TD-23972] push subscribe msg to vnode even though consumer not change
|
2023-05-06 11:06:41 +08:00 |
|
wangmm0220
|
55eddbfb5e
|
fix:[TD-23972] push subscribe msg to vnode even though consumer not change
|
2023-05-06 10:54:05 +08:00 |
|
Haojun Liao
|
1fa4327f6c
|
Merge branch 'main' into fix/liaohj_main
|
2023-05-06 10:15:23 +08:00 |
|
Haojun Liao
|
29fcd1b83a
|
refactor: do some internal refactor.
|
2023-05-06 10:08:05 +08:00 |
Haojun Liao
|
5d4a3116d5
|
Merge pull request #21139 from taosdata/fix/liaohj_main
refactor: do some internal refactor.
|
2023-05-06 09:49:26 +08:00 |
|
Haojun Liao
|
50ba55561b
|
fix(stream): set correct group id and table id.
|
2023-05-05 22:11:59 +08:00 |
|
Haojun Liao
|
8958aabe4b
|
fix(stream): opt task scan performance.
|
2023-05-05 19:33:30 +08:00 |
|
Haojun Liao
|
08ce790cda
|
fix(query): fix memory leak.
|
2023-05-05 18:20:27 +08:00 |
|
Haojun Liao
|
8b12d4d3da
|
fix(stream): secure the delete task operation. TD-1198
|
2023-05-05 15:02:03 +08:00 |
Benguang Zhao
|
c949fee06b
|
enh: commit vnode after consolidating alter hash range
|
2023-05-05 13:48:04 +08:00 |
|
Haojun Liao
|
38cbe0b768
|
fix(query): fix the invalid copmarison.
|
2023-05-05 12:52:10 +08:00 |
|
Haojun Liao
|
42b23e6471
|
fix(query): stop tsdb reader asap.
|
2023-05-05 10:40:55 +08:00 |
|
Minglei Jin
|
992480eb00
|
cache/read: fix ltype calc
|
2023-05-05 10:22:59 +08:00 |
|
Haojun Liao
|
32b4642dac
|
fix(tmq): fix invalid free.
|
2023-05-05 00:57:43 +08:00 |
|
Haojun Liao
|
25f451ba81
|
fix(tmq): fix result data block info.
|
2023-05-04 23:34:35 +08:00 |
|
Benguang Zhao
|
5d63f438b5
|
enh: confirm alter hash range
|
2023-05-04 19:43:11 +08:00 |
|
Minglei Jin
|
90be20a662
|
cache/lstring: use ltype with cache/get
|
2023-05-04 18:08:03 +08:00 |
|
Haojun Liao
|
1a8a834a2c
|
fix(tmq): fix memory leak.
|
2023-05-04 17:03:53 +08:00 |
|
Haojun Liao
|
23c49594b7
|
other: merge main.
|
2023-05-04 16:41:53 +08:00 |
|
Haojun Liao
|
09a04052ec
|
refactor: do some internal refactor.
|
2023-05-04 16:15:14 +08:00 |
|
Haojun Liao
|
11dccf12de
|
Merge pull request #21131 from taosdata/fix/liaohj_main
refactor: do some internal refactor.
|
2023-05-04 11:26:00 +08:00 |
|
Haojun Liao
|
851193a033
|
Merge pull request #21060 from taosdata/fix/TS-3222
opti:change push mgr to consume msg for subscribe
|
2023-05-04 10:16:41 +08:00 |
liuyao
|
d8a1f15d10
|
fix resum bug
|
2023-05-04 09:28:06 +08:00 |
|
Haojun Liao
|
3b814f2478
|
fix(stream): do some internal refactor.
|
2023-05-01 23:21:29 +08:00 |
|
Haojun Liao
|
3c61932ecc
|
refactor: do some internal refactor.
|
2023-05-01 19:28:54 +08:00 |
|
Haojun Liao
|
563fca5c54
|
fix(tmq): remove unnecessary error log.
|
2023-05-01 14:47:01 +08:00 |
|
Haojun Liao
|
465c595c3a
|
Merge branch 'main' into fix/liaohj_main
|
2023-04-30 18:19:35 +08:00 |
|
Haojun Liao
|
9cc4721e2a
|
refactor: do some internal refactor.
|
2023-04-30 16:37:09 +08:00 |
|
Haojun Liao
|
d8e0d02e6e
|
refactor: do some internal refactor.
|
2023-04-30 16:32:51 +08:00 |
|
Haojun Liao
|
2fe494c2c7
|
fix(query):add more check.
|
2023-04-30 02:42:26 +08:00 |
|
Haojun Liao
|
f645454f6c
|
fix(query): add check.
|
2023-04-30 01:58:08 +08:00 |
|
Haojun Liao
|
a88a4f5db0
|
fix(query): add more check for stopping tsdb reader
|
2023-04-30 01:03:13 +08:00 |
|
Haojun Liao
|
ace193ca9b
|
fix(stream): set the seek version if the reader's version is earlier than the first version in wal.
|
2023-04-29 23:34:49 +08:00 |
|
Haojun Liao
|
777ed1761f
|
refactor: update logs.
|
2023-04-29 18:24:46 +08:00 |
|
Haojun Liao
|
bbb8aaa0dc
|
refactor: add some logs.
|
2023-04-29 02:37:10 +08:00 |
|
Haojun Liao
|
8b57184a9a
|
Merge pull request #21123 from taosdata/fix/liaohj_main
refactor: remove assert.
|
2023-04-29 00:44:24 +08:00 |
|
Haojun Liao
|
b69137df44
|
refactor(log): add some logs.
|
2023-04-29 00:00:25 +08:00 |
|
Haojun Liao
|
05d416f3b9
|
fix(stream): fix invalid access when handling error, not start stream if tsDisablestream is set.
|
2023-04-28 23:53:53 +08:00 |
|
wangmm0220
|
3b66e63444
|
fix:[TD-23788] client wait if task status error in taosx transform data
|
2023-04-28 20:07:54 +08:00 |
|
Haojun Liao
|
c647ded0da
|
fix(stream): add some logs.
|
2023-04-28 19:47:49 +08:00 |
|
wangmm0220
|
8d84e8f8a5
|
fix:[TD-23788] client wait if task status error in taosx transform data
|
2023-04-28 19:29:17 +08:00 |
yihaoDeng
|
dda1c8803c
|
Merge branch 'enh/rocksdbSstate' into enh/rocksdbSstateMerge
|
2023-04-28 09:17:22 +00:00 |
|
wangmm0220
|
18d05ff69f
|
fix:memory leak
|
2023-04-28 15:53:56 +08:00 |
|
Haojun Liao
|
ad059db91b
|
Merge pull request #21120 from taosdata/fix/liaohj_main
other: add some logs.
|
2023-04-28 14:12:04 +08:00 |
|
Haojun Liao
|
b7c8346b44
|
other: merge other branch.
|
2023-04-28 13:06:47 +08:00 |
|
Haojun Liao
|
f9a64cbcd6
|
other: add some logs.
|
2023-04-28 12:58:03 +08:00 |
|
Haojun Liao
|
a0c2b34788
|
Merge pull request #21119 from taosdata/fix/liaohj_main
refactor: do some internal refactor.
|
2023-04-28 12:53:31 +08:00 |
|
Haojun Liao
|
da0d9c78ef
|
refactor: do some internal refactor.
|
2023-04-28 11:42:34 +08:00 |
|
liuyao
|
2984c5a758
|
merge main
|
2023-04-28 10:34:46 +08:00 |
|
wangmm0220
|
cce868d140
|
fix:offset encode assert error
|
2023-04-28 09:45:16 +08:00 |
|
wangmm0220
|
1ee1b0422c
|
fix:change push mgr from SArray to Hash
|
2023-04-27 23:44:27 +08:00 |
|
yihaoDeng
|
36a4413bf1
|
merge rocksdb inst
|
2023-04-27 14:38:33 +00:00 |
|
wangmm0220
|
db5b5c828e
|
fix:add log for msg push
|
2023-04-27 18:35:10 +08:00 |
|
Haojun Liao
|
ad7c3218f7
|
Merge pull request #21111 from taosdata/fix/liaohj_main
enh(query): stop tsdb reader ASAP. TD-23249
|
2023-04-27 17:45:38 +08:00 |
|
Haojun Liao
|
802c05150a
|
enh(query): stop tsdb reader ASAP.
|
2023-04-27 16:18:28 +08:00 |
|
Haojun Liao
|
e822dc2025
|
enh(query): add reader status.
|
2023-04-27 16:10:36 +08:00 |
|
Haojun Liao
|
7762e0ea47
|
refactor: do some internal refactor.
|
2023-04-27 16:10:06 +08:00 |
|
Haojun Liao
|
91f9b58f9a
|
refactor: do some internal refactor.
|
2023-04-27 16:06:06 +08:00 |
|
wangmm0220
|
8677b56a4f
|
fix:assert error in tqProcessSubmitReqForSubscribe if put pHandle to array twice
|
2023-04-27 15:44:44 +08:00 |
|
Haojun Liao
|
b7040ed15e
|
enh(stream): support resume from the latest data, and do some internal refactor.
|
2023-04-27 15:07:54 +08:00 |
|
Haojun Liao
|
e1bd65ec0a
|
Merge pull request #21105 from taosdata/fix/liaohj_main
fix(query): check the init status for pReader->status.merger TD-23903
|
2023-04-27 12:40:13 +08:00 |
|
Haojun Liao
|
3093726c5a
|
fix(query): init row merger for tsdbread.
|
2023-04-27 11:49:00 +08:00 |
|
Haojun Liao
|
fe3f3f478a
|
fix(query): check the init status for pReader->status.merger
|
2023-04-27 10:15:52 +08:00 |
|
wangmm0220
|
6a889ae80e
|
Merge branch 'main' of https://github.com/taosdata/TDengine into fix/TS-3222
|
2023-04-27 09:48:04 +08:00 |
|
Haojun Liao
|
db1d75bb48
|
refactor: do some internal refactor.
|
2023-04-27 09:28:20 +08:00 |
|
liuyao
|
863d30e5a9
|
opt tq read
|
2023-04-26 18:58:19 +08:00 |
|
wangmm0220
|
224d87b131
|
fix:cosume null if rebalance
|
2023-04-26 17:58:14 +08:00 |
|
Haojun Liao
|
9a35d4e950
|
Merge pull request #21087 from taosdata/fix/liaohj_main
refactor: do some internal refactor.
|
2023-04-26 17:57:37 +08:00 |
|
Minglei Jin
|
a1fba2df65
|
Merge branch '3.0' into fix/TD-23623
|
2023-04-26 17:38:47 +08:00 |
|
Haojun Liao
|
ca4df761f1
|
fix(query): fix syntax error.
|
2023-04-26 17:14:54 +08:00 |
|
Haojun Liao
|
627429d490
|
fix(query): fix the comparion error.
|
2023-04-26 16:05:57 +08:00 |
|
Haojun Liao
|
3e80f57fc7
|
refactor: do some internal refactor.
|
2023-04-26 12:09:05 +08:00 |
|
Haojun Liao
|
59725d1d87
|
refactor: do some internal refactor.
|
2023-04-26 12:02:43 +08:00 |
|
Haojun Liao
|
8d0a4772a5
|
Merge pull request #21070 from taosdata/fix/liaohj_main
enh(query): opt last row read performance. TD-23313
|
2023-04-26 11:54:48 +08:00 |
Hui Li
|
133327140f
|
Merge pull request #21078 from taosdata/fix/TS-3267
fix: more fix
|
2023-04-26 10:42:09 +08:00 |
|
Minglei Jin
|
6835e75903
|
cache/get: malloc zero-length binary to unify frees
|
2023-04-26 10:07:15 +08:00 |
|
Haojun Liao
|
8e2edd6ebf
|
fix(query): fix null ptr access.
|
2023-04-26 10:00:00 +08:00 |
|
Minglei Jin
|
5758aa4d80
|
cache/read: fix pRow, pLastCols memory issues
|
2023-04-26 08:17:08 +08:00 |
|
Haojun Liao
|
2a45ef88b0
|
fix(query): fix memory leak.
|
2023-04-26 00:40:33 +08:00 |
|
Haojun Liao
|
7b7a483afc
|
fix(query): add tmp variable to hold the TSDBROW value.
|
2023-04-25 18:43:48 +08:00 |
|
Minglei Jin
|
c8cbabe419
|
cache/none column: move to outter scope
|
2023-04-25 18:13:33 +08:00 |
Hongze Cheng
|
49728a235e
|
fix: more fix
|
2023-04-25 17:32:45 +08:00 |
|
54liuyao
|
b79313ecd7
|
pause&resume
|
2023-04-25 16:59:09 +08:00 |
|
wangmm0220
|
4321012ac4
|
Merge branch 'main' of https://github.com/taosdata/TDengine into fix/TS-3222
|
2023-04-25 16:24:28 +08:00 |
|
wangmm0220
|
d1e5d6e0f9
|
fix:pHandle->msg is not null if rebalance
|
2023-04-25 16:23:58 +08:00 |
slzhou
|
aede1090ff
|
fix: the latest schema may delete columns
|
2023-04-25 16:23:30 +08:00 |
|
Minglei Jin
|
2566bd4ae8
|
row/iter: fix null column iter
|
2023-04-25 16:17:58 +08:00 |
|
Haojun Liao
|
16fe48f770
|
fix(query): fix memory leak.
|
2023-04-25 16:09:58 +08:00 |
|
Haojun Liao
|
bca5fc7893
|
fix(query): fix memory leak.
|
2023-04-25 15:28:54 +08:00 |
cadem
|
2fd9640a39
|
change learner config format
|
2023-04-25 15:15:28 +08:00 |
|
Haojun Liao
|
8dbc3b3457
|
refactor: do some internal refactor.
|
2023-04-25 15:07:37 +08:00 |
|
Haojun Liao
|
0b6e531dd3
|
refactor: do some internal refactor.
|
2023-04-25 14:56:20 +08:00 |
|
Haojun Liao
|
81e54541de
|
refactor: do some internal refactor.
|
2023-04-25 14:24:24 +08:00 |
|
Haojun Liao
|
05d1692073
|
refactor: do some internal refactor.
|
2023-04-25 13:50:05 +08:00 |
|
Haojun Liao
|
d8762b9bc9
|
refactor: do some internal refactor.
|
2023-04-25 10:48:21 +08:00 |
|
Haojun Liao
|
6467b99a52
|
refactor: do some internal refactor.
|
2023-04-25 10:23:21 +08:00 |
|
Haojun Liao
|
4c4e148635
|
refactor: do some internal refactor.
|
2023-04-25 10:19:37 +08:00 |
|
wangmm0220
|
41bec8560a
|
opti:change push mgr to consume msg for subscribe
|
2023-04-25 09:58:28 +08:00 |
|
Haojun Liao
|
e724bc15e0
|
refactor: do some internal refactor.
|
2023-04-25 09:54:00 +08:00 |
|
Hongze Cheng
|
d57676c924
|
fix: delete table error
|
2023-04-25 09:52:16 +08:00 |
|
Minglei Jin
|
33fba6f99a
|
cache/read: fix transferBuf index
|
2023-04-25 09:48:56 +08:00 |
|
Haojun Liao
|
ae8a9d25c0
|
refactor: do some internal refactor.
|
2023-04-25 09:41:49 +08:00 |
|
Haojun Liao
|
a73957aaba
|
fix(query): fix error in add row into merger.
|
2023-04-25 09:24:15 +08:00 |
|
Haojun Liao
|
37d042a338
|
fix(query): fix error in add row into merger.
|
2023-04-25 00:33:24 +08:00 |
|
Haojun Liao
|
9a14e0db47
|
fix(query): fix error in add row into merger.
|
2023-04-25 00:30:43 +08:00 |
|
Haojun Liao
|
c6daa68e54
|
enh(query): opt merge life cycle.
|
2023-04-25 00:17:37 +08:00 |
|
wangmm0220
|
8572f4a32f
|
opti:change push mgr to consume msg for subscribe
|
2023-04-24 19:41:30 +08:00 |
|
Minglei Jin
|
4adc95f9db
|
cache/deserialize: fix binary pData calc
|
2023-04-24 18:21:25 +08:00 |
|
Minglei Jin
|
3b88efbd5f
|
cache/delete: fix null column values
|
2023-04-24 17:07:20 +08:00 |
|
Haojun Liao
|
7360a6b65c
|
enh(query): opt hash.
|
2023-04-24 16:39:55 +08:00 |
|
Haojun Liao
|
d73306f616
|
enh(query): opt last row read performance.
|
2023-04-24 16:08:49 +08:00 |
|
Haojun Liao
|
5663550de2
|
enh(query): opt query perf by allocate the SLDataIter when opening reader.
|
2023-04-24 15:47:02 +08:00 |
|
Minglei Jin
|
c7d5b48920
|
cache/read: fix pRes buffer index
|
2023-04-24 15:42:53 +08:00 |
Xiaoyu Wang
|
f5a974489e
|
Merge pull request #21045 from taosdata/fix/block-check-to-async-check
fix/block-check-to-async-check
|
2023-04-24 15:41:17 +08:00 |
|
Haojun Liao
|
48c36a8c35
|
Merge branch 'main' into enh/rocksdbSstate
|
2023-04-24 14:44:13 +08:00 |
|
Minglei Jin
|
f8bf98f6dc
|
Merge branch '3.0' into fix/TD-23623
|
2023-04-24 14:28:49 +08:00 |
|
Haojun Liao
|
fa46165227
|
Merge branch 'main' into enh/rocksdbSstate
|
2023-04-24 12:59:24 +08:00 |
|
Haojun Liao
|
057cc2d30d
|
Merge pull request #21018 from taosdata/feature/3_liaohj
fix(stream): set the correct start offset for stream task.
|
2023-04-24 12:02:20 +08:00 |
|
Minglei Jin
|
8f21090343
|
cache/delete: just remove affected cache entries
|
2023-04-24 10:47:28 +08:00 |
|
cadem
|
a781d43577
|
fix/block-check-to-async-check
|
2023-04-24 10:23:43 +08:00 |
|
wangmm0220
|
9bd74ec5b2
|
Merge branch 'fix/TS-3222' of https://github.com/taosdata/TDengine into fix/TS-3222
|
2023-04-24 10:14:32 +08:00 |
|
Haojun Liao
|
134c0528ae
|
Merge branch 'main' into fix/liaohj_main
|
2023-04-24 01:43:00 +08:00 |
|
wangmm0220
|
77e03bfd78
|
opti:change push mgr to consume msg for subscribe
|
2023-04-23 20:14:49 +08:00 |
|
liuyao
|
641c707b37
|
pause&resume
|
2023-04-23 17:37:10 +08:00 |
|
wangmm0220
|
4bc319c6dd
|
Merge branch 'main' of https://github.com/taosdata/TDengine into fix/TS-3222
|
2023-04-23 15:15:33 +08:00 |
|
Xiaoyu Wang
|
35f02cdbad
|
Merge pull request #21013 from taosdata/FIX/TD-23768-main
fix: change tdbTbInsert to tdbTbUpsert for meta update in tdb
|
2023-04-23 15:15:17 +08:00 |
|
liuyao
|
5bd8fe5441
|
feat:add pause&resume
|
2023-04-23 15:09:01 +08:00 |
|
54liuyao
|
5089528a02
|
feat:stream pause&resume
|
2023-04-23 15:08:51 +08:00 |
|
Haojun Liao
|
6fc364db19
|
fix(query): add null ptr check.
|
2023-04-23 13:53:55 +08:00 |
|
Haojun Liao
|
9cf89c6b6f
|
enh(tmq): add check for consumer Id;
|
2023-04-23 11:51:43 +08:00 |
Xiaoyu Wang
|
206887166c
|
fix: vnode errcode setting error
|
2023-04-23 10:53:28 +08:00 |
|
yihaoDeng
|
917b07348c
|
Merge branch 'fix/rocksdbState' into enh/rocksRevert
|
2023-04-23 02:37:26 +00:00 |
|
Haojun Liao
|
3dbe208712
|
enh(tmq): fix memory error and add retrieve wal info as required.
|
2023-04-22 15:34:46 +08:00 |
|
Benguang Zhao
|
3c53516299
|
fix: use tdbTbUpsert for metaUpdate functions
|
2023-04-21 19:24:09 +08:00 |
|
Minglei Jin
|
9918d326cc
|
Merge branch '3.0' into fix/TD-23623
|
2023-04-21 18:39:07 +08:00 |
|
Minglei Jin
|
a75d43a259
|
cache/read: remove unused extract function
|
2023-04-21 18:38:20 +08:00 |
|
Minglei Jin
|
12fc21ae84
|
cache/get: use pRow from reader
|
2023-04-21 18:34:58 +08:00 |
|
wangmm0220
|
6efbcfec4b
|
Merge branch 'main' of https://github.com/taosdata/TDengine into fix/TS-3222
|
2023-04-21 17:46:35 +08:00 |
|
Minglei Jin
|
09c62e6ca2
|
fix values_list index when freeing
|
2023-04-21 16:30:00 +08:00 |
|
Minglei Jin
|
8e87b21a59
|
rocks/multi_get value: free rocks allocated memory
|
2023-04-21 16:23:40 +08:00 |
chenhaoran
|
7d7a0769b3
|
Merge remote-tracking branch 'origin/main' into enh/tsbsPerf.1
|
2023-04-21 16:20:37 +08:00 |
|
Minglei Jin
|
01d95b5e95
|
cache/read: use new interface with signle query
|
2023-04-21 16:07:22 +08:00 |