Commit graph

6083 commits

Author SHA1 Message Date
Haojun Liao
3d00f6ce54 refactor: do some internal refactor. 2023-05-14 22:08:17 +08:00
Haojun Liao
8e15c64499 refactor: do some internal refactor. 2023-05-13 23:22:36 +08:00
Haojun Liao
170c603995 other: merge 3.0 2023-05-13 20:16:55 +08:00
Haojun Liao
99148d6719 other: merge 3.0 2023-05-13 20:02:48 +08:00
Haojun Liao
236926b9ee other: merge enh/rocksdbstate 2023-05-13 19:49:28 +08:00
Haojun Liao
1975e94501 Merge branch 'main' into enh/rocksdbSstate 2023-05-13 19:41:03 +08:00
Haojun Liao
40ffe0cd83 fix(tmq): check handle status before close sub. 2023-05-13 16:45:21 +08:00
Haojun Liao
b383651d8b fix(tmq): fix the invalid write and set the flag when closing taosx sub. 2023-05-13 16:17:26 +08:00
Haojun Liao
5b2ef2a675 other: merge main and remove invalid return data for poll. 2023-05-13 02:31:39 +08:00
dapan1121
3ca5559b37 fix: invalid read issue 2023-05-12 19:27:11 +08:00
dapan1121
1a52b3d519 fix: taosd crash issue 2023-05-12 18:13:16 +08:00
Haojun Liao
99422c87c3 fix(tq): set the offset to be the consume offset, instead of the committed offset. And update the table sim. 2023-05-12 16:14:56 +08:00
dapan1121
69795286fa Merge remote-tracking branch 'origin/main' into enh/tsbsPerf.4 2023-05-12 13:46:16 +08:00
dapan1121
0dd0b16842 enh: optimize table scan for last query 2023-05-12 13:30:17 +08:00
Haojun Liao
7ef16e1922 other: merge main. 2023-05-12 11:49:53 +08:00
wangmm0220
cd105381a9 fix:[TD-24111]avoid exec pHandle task in multi query thread 2023-05-12 11:41:59 +08:00
wangmm0220
d85f0f56d5 fix:[TD-24111]avoid exec pHandle task in multi query thread 2023-05-12 10:51:13 +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
liuyao
8b7b804606 opt partition by tbname 2023-05-11 18:47:27 +08:00
Haojun Liao
26bea33ccc fix(tmq): add null check for print log. 2023-05-11 17:56:19 +08:00
Haojun Liao
a76e47ef54 refactor: add some logs. 2023-05-11 14:19:27 +08:00
Haojun Liao
f0f90888ab refactor: update some logs. 2023-05-11 13:48:50 +08:00
Haojun Liao
2b736ffd60 fix(stream): avoid duplicated task id in task id list. 2023-05-11 11:47:57 +08:00
Haojun Liao
8a1b0ed052 refactor: do some internal refactor. 2023-05-11 10:35:09 +08:00
Haojun Liao
b02b3117b5 refactor: do some internal refactor. 2023-05-11 10:14:29 +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
yihaoDeng
5708fcb5cb Merge branch 'enh/3.0' into enh/rocksdbSstateMerge 2023-05-10 08:02:16 +00: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
Yihao Deng
c6e5879f44
Merge branch 'main' into enh/rocksdbSstate 2023-05-10 10:04:28 +08:00
yihaoDeng
8356533eb1 Merge branch 'enh/standVer' into enh/rocksdbSstateMerge 2023-05-09 12:13:16 +00: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
dapan1121
52fd6a84ac enh: support db cfg cache update 2023-05-09 17:04:20 +08:00
yihaoDeng
55014aa003 Merge branch 'enh/rocksdbSstate' into enh/rocksdbSstateMerge 2023-05-09 08:58:51 +00: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
Yihao Deng
cb223acf82
Merge branch 'main' into enh/rocksdbSstate 2023-05-08 09:45:27 +08:00
yihaoDeng
08c3a63341 Merge branch 'enh/standVer' into enh/rocksdbSstateMerge 2023-05-06 12:37:54 +00:00
dapan1121
c83367e455 enh: add table group cache 2023-05-06 19:24:47 +08:00
Haojun Liao
9392c03b7f fix(stream): add some logs. 2023-05-06 19:05:55 +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
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