Haojun Liao
|
7ef16e1922
|
other: merge main.
|
2023-05-12 11:49:53 +08:00 |
Haojun Liao
|
26f94ecd60
|
Merge pull request #21260 from taosdata/feature/3_liaohj
fix(tmq): update the local offset when retrieving offset from vnode.
|
2023-05-11 23:12:33 +08:00 |
|
Haojun Liao
|
26bea33ccc
|
fix(tmq): add null check for print log.
|
2023-05-11 17:56:19 +08:00 |
Minglei Jin
|
81d4673153
|
cache/get: clear writebatch after writing
|
2023-05-10 17:52:26 +08:00 |
|
Minglei Jin
|
74c9a4b80b
|
Merge branch '3.0' into fix/TS-3181
|
2023-05-10 17:42:46 +08:00 |
|
Minglei Jin
|
10cee51d32
|
fix(cache/get): move rocks wring out of column iterating
|
2023-05-10 17:32:51 +08:00 |
|
Minglei Jin
|
9bbf36d35d
|
cache/serialize: keep original col value untouched
|
2023-05-10 14:39:51 +08:00 |
|
Minglei Jin
|
84987c494a
|
cache/fs: fix primary ts column loading
|
2023-05-10 12:25:36 +08:00 |
Hui Li
|
b1b85c3d95
|
Merge pull request #21227 from taosdata/fix/TD-24058
fix:[TD-24058]send poll result to client if no data 5 times to avoid …
|
2023-05-10 11:12:20 +08:00 |
|
Minglei Jin
|
0958fe5635
|
cache/binary: memcpy binary pData if pLastCol is from rocks lookup
|
2023-05-10 10:15:48 +08:00 |
dapan1121
|
d0e26d2efc
|
Merge pull request #21216 from taosdata/fix/TS-3358
fix:after restarting taosd, stream does not work.
|
2023-05-09 19:01:43 +08:00 |
|
dapan1121
|
39adac8537
|
Merge pull request #21224 from taosdata/fix/TS-3376
fix: fix crash caused by tsdbReaderResume error not handled
|
2023-05-09 18:56:36 +08:00 |
wangmm0220
|
587f750c94
|
fix:[TD-24058]send poll result to client if no data 5 times to avoid lost data
|
2023-05-09 17:42:11 +08:00 |
liuyao
|
8224d49702
|
fix:after restarting taosd, stream does not work.
|
2023-05-09 17:24:11 +08:00 |
Ganlin Zhao
|
76dd5a962a
|
fix: fix crash caused by tsdbReaderResume error not handled
|
2023-05-09 17:19:45 +08:00 |
|
Minglei Jin
|
412fc9b0bc
|
cache/memory: fix double free issue with tsim/parser/last_cache.sim
|
2023-05-09 11:09:53 +08:00 |
|
Minglei Jin
|
064c46bc7b
|
cache/dclp: double check to load from tsdb
|
2023-05-09 09:17:26 +08:00 |
|
dapan1121
|
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 |
|
Minglei Jin
|
9b275f7421
|
cache/last_row cid: first round implementation for last_row with cid
|
2023-05-08 17:33:35 +08:00 |
|
Minglei Jin
|
e0f0536d2d
|
cache/serialize: nullize pData if zero-length
|
2023-05-08 15:56:54 +08:00 |
|
Minglei Jin
|
5349fac910
|
cache/last: use rowTs instead of lastRowTs
|
2023-05-08 11:33:01 +08:00 |
|
Minglei Jin
|
2eec395720
|
cache/commit: flush cache when tsdb commits data
|
2023-05-08 11:14:59 +08:00 |
|
Minglei Jin
|
198ce399d2
|
cache/get: store recalced column value back into rocks
|
2023-05-08 10:59:56 +08:00 |
|
Haojun Liao
|
c6007d53e8
|
Merge pull request #21190 from taosdata/fix/TS-3347
fix:[TS-3347]set ver to first version if version stored is smaller th…
|
2023-05-06 18:51:49 +08:00 |
|
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 |
|
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
|
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 |
|
Haojun Liao
|
3b814f2478
|
fix(stream): do some internal refactor.
|
2023-05-01 23:21:29 +08:00 |