Commit Graph

10393 Commits

Author SHA1 Message Date
Shengliang Guan 6dedab4bba
Merge pull request #29784 from taosdata/fix/TS-6017-3.0m
fix: timeseries statistics and test case
2025-02-17 10:25:44 +08:00
Shengliang Guan 596e381e0e
Merge pull request #29779 from taosdata/fix/metanull
fix(stream): access value after null ptr check.
2025-02-17 09:36:09 +08:00
Haojun Liao 57a2471cc6 fix(stream): add missing release 2025-02-15 00:03:33 +08:00
kailixu 5fa20d8cb3 Merge branch 'main' into fix/TS-6017-3.0m 2025-02-14 17:02:47 +08:00
kailixu 6885b942b1 fix: timeseries statistics and test case 2025-02-14 16:53:32 +08:00
Shengliang Guan d6bd52ece7
Merge pull request #29750 from taosdata/enh/streamqueue
refactor(stream): add more operation handled in ctrl queue, and limit the stream input q size
2025-02-14 15:02:23 +08:00
Haojun Liao 03041d0f61 other: merge main 2025-02-14 10:18:19 +08:00
kailixu e3aaab405d fix: timeseries statistics and test case 2025-02-13 18:55:28 +08:00
kailixu 61a606a410 fix: timeseries calculation when create table 2025-02-13 14:03:54 +08:00
Haojun Liao 81b718ec69 refactor(stream): handle retrieve chkpt trigger in ctrl queue. 2025-02-11 13:07:06 +08:00
Haojun Liao 9ad6fd170b fix(stream): update the process queue. 2025-02-10 19:24:36 +08:00
Shengliang Guan dae17cd1b0
Merge pull request #29718 from taosdata/enh/streamqueue
refactor(stream): notify close stream in main thread
2025-02-10 18:44:27 +08:00
Haojun Liao 694b6385d5 refactor(stream): adjust reset and mark failed Id. 2025-02-09 21:40:33 +08:00
Haojun Liao a2dcba10a7 refactor(stream): 1) notify closing in main thread. 2) not saving the halt status. 2025-02-09 01:42:24 +08:00
Jinqing Kuang d32cf8bcb8 fix(query)[TS-5984]. correct data block filtering logic in tsdbReader
When scanning a table with a primary key, tsdbReader could load
irrelevant data blocks outside the query time range, causing errors
when returning results.

This fix improves filtering logic to ensure only valid blocks are
read and adds test verification.
2025-02-08 17:32:25 +08:00
Haojun Liao a5cdf3320c refactor(stream): handle stream check in ctrl queue. 2025-02-05 15:03:30 +08:00
Haojun Liao 0f04f47337 refactor(stream): dispatch req handled in ctrl queue. 2025-02-05 15:03:24 +08:00
Haojun Liao fa2229c453 refactor(stream): dispatch rsp handled in ctrl queue. 2025-02-05 15:03:10 +08:00
Haojun Liao 5e130c4d53 enh(stream): add ctrl queue to handle hb rsp, to avoid hb rsp not being confirmed if all stream threads are occupied. 2025-02-05 14:57:15 +08:00
Haojun Liao 79284e7414 Merge branch 'main' into fix/disp_lost 2025-01-24 17:15:22 +08:00
Haojun Liao 093233203d
Revert "refactor(stream): do some internal refactor ." 2025-01-24 17:11:15 +08:00
Shengliang Guan 3089e3d904
Merge pull request #29544 from taosdata/fix/tag
refactor(stream): do some internal refactor .
2025-01-24 16:27:22 +08:00
Pan Wei d6633a27ac
Merge pull request #29651 from taosdata/fix/addMetaDebugLog.m
fix: add table meta validation error and debug log
2025-01-24 09:54:36 +08:00
dapan1121 bd450fe751 fix: add meta debug log 2025-01-23 16:12:54 +08:00
Haojun Liao 963e397984 fix(stream): update logs. 2025-01-23 14:45:47 +08:00
Hongze Cheng 3405a007bd enh: accelerate tsdb snapshot when data are all in stt file 2025-01-23 14:23:54 +08:00
Haojun Liao 6cc3b5da0e fix(stream): add upper bound for the time of waiting for creating table. 2025-01-23 13:37:41 +08:00
Haojun Liao e5e57923cd fix(stream): add upper bound for the time of waiting for creating table. 2025-01-23 13:18:56 +08:00
dapan1121 89cea7859a fix: invalid subtable in tbname in clause issue 2025-01-21 17:41:37 +08:00
Haojun Liao 84eaed0bbb fix(stream): fix invalid read. 2025-01-19 00:13:58 +08:00
Haojun Liao b4a6523aa6 fix(stream): fix invalid read. 2025-01-18 01:35:24 +08:00
Haojun Liao c93fe999ba refactor(stream): injection error. 2025-01-18 01:26:49 +08:00
Haojun Liao 6274eea7c4 fix(stream): adjust the free stream meta position and check the close flag of streamMeta before starting scan wal. 2025-01-17 19:15:08 +08:00
Haojun Liao 3223cc0287 other: add todo 2025-01-09 18:37:05 +08:00
Shengliang Guan 081c902c64
Merge pull request #29520 from taosdata/fix/TD-32471-main
fix:[TD-32471]set error code to terrno if tmq_consumer_poll return NULL
2025-01-09 13:33:48 +08:00
Hongze Cheng dbfb910bff
Merge pull request #29522 from taosdata/fix/TS-5853-main
enh: add strict message check for submit message
2025-01-09 13:18:38 +08:00
Hongze Cheng c2528b8535 more code 2025-01-09 11:11:19 +08:00
Haojun Liao 30039bb53b enh(stream): add ctrl queue to handle hb rsp, to avoid hb rsp not being confirmed if all stream threads are occupied. 2025-01-09 09:17:08 +08:00
Hongze Cheng a881103c86 more code 2025-01-08 18:13:10 +08:00
Shengliang Guan 37eb686d7c
Merge pull request #29502 from taosdata/fix/main/TD-33457
Fix(cfg): resolve dynamic configuration update failure after rolling …
2025-01-08 17:31:13 +08:00
Hongze Cheng 00b0a46060 enh: add strict message check for submit message 2025-01-08 17:29:32 +08:00
wangmm0220 ba9892bae0 fix:[TD-32471]set error code to terrno if tmq_consumer_poll return NULL 2025-01-08 16:50:38 +08:00
xiao-77 77359f26b3 Fix(cfg): resolve dynamic configuration update failure after rolling upgrade to 3.3.5.0 2025-01-07 15:26:01 +08:00
Hongze Cheng bb01c4d763 fix: compile issue 2025-01-07 15:13:26 +08:00
Hongze Cheng 4587beb849 fix: meta entry snapshot problem for old version 2025-01-07 14:09:29 +08:00
Shengliang Guan b81ade633f
Merge pull request #29478 from taosdata/fix/TD-33440-3.0m
fix: eliminate duplicated read locks in one thread
2025-01-06 13:34:19 +08:00
kailixu c69215576d fix: eliminate duplicated read locks in one thread 2025-01-03 19:00:06 +08:00
Hongze Cheng 55a27061da fix: possible snapshot.py fail 2025-01-03 15:51:59 +08:00
Shengliang Guan 0bbbab1bfa
Merge pull request #29447 from taosdata/fix/tag
fix(stream): fix dead-lock caused by invalid repeatly unlock.
2025-01-02 14:02:35 +08:00
Haojun Liao 055441d8fb fix(stream): fix dead-lock caused by invalid repeatly unlock. 2025-01-02 09:55:05 +08:00