Commit Graph

194 Commits

Author SHA1 Message Date
yihaoDeng f7a7743af7 fix case failure 2023-05-05 08:32:33 +00:00
liuyao 74ab689719 opt batch num 2023-05-05 08:59:07 +08:00
yihaoDeng c27d01a510 Merge branch 'enh/addTtlToStream' into enh/rocksdbSstateMerge 2023-05-04 08:22:31 +00:00
yihaoDeng dda1c8803c Merge branch 'enh/rocksdbSstate' into enh/rocksdbSstateMerge 2023-04-28 09:17:22 +00:00
yihaoDeng 36a4413bf1 merge rocksdb inst 2023-04-27 14:38:33 +00:00
liuyao 863d30e5a9 opt tq read 2023-04-26 18:58:19 +08:00
liuyao eca7b68fa0 ignore update 2023-04-24 15:01:56 +08:00
yihaoDeng 98d6ff5a5d change write opt 2023-04-21 05:55:10 +00:00
yihaoDeng 57c4544bf0 change write opt 2023-04-21 05:54:52 +00:00
54liuyao 5b7ccc42ca inc sleep time 2023-04-19 13:38:30 +08:00
liuyao ae117bd7c3 fill state 2023-04-19 09:15:12 +08:00
liuyao b8ac811f20 fix bug 2023-04-14 17:35:17 +08:00
Haojun Liao 5850a3ab01 Merge remote-tracking branch 'origin/enh/rocksRevert' into enh/rocksRevert 2023-04-14 10:37:17 +08:00
Haojun Liao b57c813681 other: merge feature/3_liaohj 2023-04-14 10:36:54 +08:00
liuyao 34bf638f19 fix bug 2023-04-13 16:21:57 +08:00
liuyao 9be89ce00a delete expired check point 2023-04-12 17:33:58 +08:00
yihaoDeng b24b91886a Merge branch 'dev3' into enh/rocksRevert 2023-04-11 10:59:00 +00:00
liuyao 95d81604c7 feat:encode&&decode stream scan op 2023-04-11 14:34:31 +08:00
liuyao 74da3c05bc feat:set check point id 2023-04-11 10:33:10 +08:00
Haojun Liao f5b52749c2 refactor: do some internal refactor. 2023-04-09 01:39:09 +08:00
liuyao 955f8f9f07 feat:optimize get patitionby name 2023-04-07 18:45:09 +08:00
liuyao 1f63859e21 feat:add buff swap 2023-04-07 12:50:59 +08:00
liuyao 0716a4aee8 feat:add check point 2023-04-06 16:45:22 +08:00
54liuyao 1892b806b5 feat:add stream state buff 2023-04-04 17:09:35 +08:00
54liuyao 429b5cd646 feat:add stream file state 2023-04-04 17:09:35 +08:00
yihaoDeng 009d5099b4 reset version 2023-03-30 01:53:26 +00:00
yihaoDeng 0d11430be1 tqadd backend 2023-03-28 14:31:11 +00:00
yihaoDeng a3a0d9c81f add backend 2023-03-27 07:42:11 +00:00
yihaoDeng c3d7f888e9 add backend 2023-03-26 05:46:48 +00:00
yihaoDeng b9531fc9a7 add backend 2023-03-25 06:46:19 +00:00
yihaoDeng 8e409f81ae add backend 2023-03-25 06:43:17 +00:00
yihaoDeng b17f99de47 add backend 2023-03-23 12:49:33 +00:00
yihaoDeng 981466a0c7 failed to read from 2023-03-22 14:35:24 +00:00
yihaoDeng b701198dbb add backend 2023-03-22 13:19:56 +00:00
dapan1121 5b02af6a91 fix: merge main to 3.0 2023-03-22 16:08:16 +08:00
yihaoDeng 914d391845 fix tag filter 2023-03-21 12:28:16 +00:00
yihaoDeng 2d37aeabdc add backend 2023-03-20 15:33:18 +00:00
yihaoDeng 05a205d3b8 add backend 2023-03-20 02:00:31 +00:00
yihaoDeng e04de7f6df add backend 2023-03-18 07:37:54 +00:00
yihaoDeng 8039702c14 add backend 2023-03-18 07:36:55 +00:00
54liuyao 96db1192ae fix: fix coverity scan 2023-03-15 09:03:05 +08:00
Xiaoyu Wang c597de099f merge main 2023-02-20 13:41:27 +08:00
Liu Jicong 7a4c8f30db reset default cfg 2023-02-13 10:54:13 +08:00
Liu Jicong 1114fef337 add cfg 2023-02-13 09:47:30 +08:00
Xiaoyu Wang b2e60da1cf merge main 2023-02-10 10:34:55 +08:00
Xiaoyu Wang 09925437e3 merge main 2023-02-08 09:51:52 +08:00
Minglei Jin f4a60a4364 fix(stream/state): switch tdb rollback on to restore from journals 2023-02-07 15:11:22 +08:00
Xiaoyu Wang 5d499e52f9 merge main 2023-02-03 17:13:11 +08:00
Minglei Jin df30b51a75 fix(stream): use tdb page replacement with stream state 2023-02-01 17:59:39 +08:00
54liuyao e03deeaed8 feat:add stream delete mark 2023-01-17 16:21:51 +08:00
Minglei Jin a2e35ce13b streamState/tdb: use NULL for tdbBegin's heap source 2023-01-12 11:26:13 +08:00
Liu Jicong 65e7dbda0c enh: enlarge state buffer size 2023-01-06 17:37:45 +08:00
Liu Jicong 095c6d39ca reset param 2022-12-30 17:30:02 +08:00
Liu Jicong 7721353b6b enh: put func state into tdb 2022-12-29 12:39:07 +08:00
Shengliang Guan 78c14a2c88 Merge remote-tracking branch 'origin/3.0' into merge/mainto3.0_1228 2022-12-28 14:59:02 +08:00
54liuyao 70ffbabcbf fix:remove assert 2022-12-26 10:15:14 +08:00
Liu Jicong 2a7de0cd46 refactor: remove assert 2022-12-21 13:54:14 +08:00
Shengliang Guan 6d94afe48f
Revert "refact: adjust some assert cases" 2022-12-07 21:51:17 +08:00
Shengliang Guan d5126d469a refact: replcase ASSERT with tAssert 2022-12-07 18:42:48 +08:00
Minglei Jin 2c771153ef fix(streamState): use new txn related api 2022-11-28 16:27:20 +08:00
Minglei Jin 506554b5d2 Merge branch 'v3.0' into fix/tdb-async-commit 2022-11-28 16:20:48 +08:00
Minglei Jin ada76477fc fix: free stream state cursor 2022-11-21 11:54:25 +08:00
54liuyao 3e29f19782 fix:stream state abnormal failure 2022-11-20 10:32:25 +08:00
Liu Jicong 9a603e5663 enh(stream): put user defined tb name into stream state 2022-11-18 17:21:50 +08:00
Minglei Jin 78335f83d2 tdb/api: migrate txn related api changes of meta, sma, tq, and stream meta/state 2022-11-17 20:02:13 +08:00
Liu Jicong aa9e935854 enh(stream): set path max length to 1024 2022-11-14 14:46:50 +08:00
54liuyao 7ea790021f fix:avoid duplicate results 2022-11-11 16:18:54 +08:00
54liuyao f66eded1e1 fix(stream): state window, error result after deleting data 2022-11-08 14:40:44 +08:00
Minglei Jin 1a4cf6964b fix: add post commit to tq & stream 2022-11-07 20:34:23 +08:00
54liuyao 7d8a282258 fix(stream):tqBuildDeleteReq error 2022-10-28 11:19:26 +08:00
54liuyao 5cee271cbc fix(stream): stream state invalid cur 2022-10-24 13:28:13 +08:00
54liuyao d9beaeb3a3 fix(stream):session window max_delay crash 2022-10-21 11:49:45 +08:00
54liuyao 368f5134c5 feat(stream):optimize state window disc buff 2022-10-20 09:04:51 +08:00
Hongze Cheng efa9f19d18 make it compile 2022-10-19 09:12:37 +08:00
Hongze Cheng 71a2db6cf2 Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/commit_txn 2022-10-19 09:10:36 +08:00
Minglei Jin 82132cdfdd meta: new metaFinishCommit api & rollback parameter with metaOpen 2022-10-18 18:34:39 +08:00
54liuyao 8efd7e8763 feat(stream):replace disk buff 2022-10-18 18:13:47 +08:00
Liu Jicong a57a305035 fix(stream): memory leak 2022-10-14 14:43:22 +08:00
Liu Jicong d507678b35 refactor(stream): set state buffer size 2022-10-13 11:18:02 +08:00
Liu Jicong db6b0503a1 refactor(stream): change state table name 2022-10-12 14:34:04 +08:00
Liu Jicong eafe8666f7 merge 3.0 2022-10-09 17:00:18 +08:00
Liu Jicong 2f9aeeb5fc feat(stream): support define table name 2022-10-09 16:54:27 +08:00
54liuyao 9c170ecfa8 fix(stream): filter error occurred when data was modified 2022-10-09 14:52:39 +08:00
54liuyao f569355d06 fix(stream):memory leak 2022-10-08 11:04:36 +08:00
54liuyao 46c99915bc feat(stream): distribute interval disc buff 2022-09-30 10:01:51 +08:00
Cary Xu 9e49eb03e4 fix: coverity scan for sma 2022-09-28 18:54:39 +08:00
54liuyao 747297bd28 feat(stream): stream fill 2022-09-27 18:11:44 +08:00
54liuyao 97ca09689c Merge branch 'feature/stream' into feature/TD-18820 2022-09-19 19:31:41 +08:00
Liu Jicong 86c0fb56e0 enhance stream backend for sma 2022-09-19 17:27:25 +08:00
54liuyao 955838d1f6 feat(stream): optimize disc buff 2022-09-19 17:13:13 +08:00
Liu Jicong 4c6a8bbc95 feat(stream): stream state support tuple 2022-09-14 16:50:42 +08:00
54liuyao 1f5d9a38e7 feat(stream):change single interval disc buff and interval delete 2022-09-07 14:48:14 +08:00
Liu Jicong 24261cc90b refactor(stream): refine stream backend interface 2022-08-24 15:53:29 +08:00
Liu Jicong 2d628491b2 feat(stream): support tdb state backend 2022-08-23 19:30:04 +08:00