Commit Graph

16029 Commits

Author SHA1 Message Date
Haojun Liao 0f9328330b fix(stream): disable continue check for downstream tasks. 2023-10-24 11:56:36 +08:00
Haojun Liao 7a8b046a35 fix(sma): fix bugs in sma and do some internal refactor. 2023-10-24 09:40:38 +08:00
yihaoDeng 09192acf96 fix mem leak 2023-10-23 10:20:57 +08:00
Haojun Liao 059e94e428 fix(stream): clear flag for checkpoint. 2023-10-22 01:25:00 +08:00
Haojun Liao 4826b34a2b refactor: do some internal refactor. 2023-10-21 16:32:44 +08:00
Haojun Liao 06cd67e26e refactor: do some internal refactor. 2023-10-21 16:20:03 +08:00
Haojun Liao 21e98e358e fix(stream): clear the flag. 2023-10-21 02:41:03 +08:00
Haojun Liao d1095e2c4c Merge remote-tracking branch 'origin/refact/streamsm' into refact/streamsm 2023-10-21 01:42:59 +08:00
Haojun Liao 49014d4b68 fix(stream): update the nodeEp even during checkpoint trans. 2023-10-21 01:42:43 +08:00
yihaoDeng aaf7e070ee Merge branch 'refact/streamsm' of https://github.com/taosdata/TDengine into refact/streamsm 2023-10-20 20:49:17 +08:00
yihaoDeng e95735eea4 fix mem leak 2023-10-20 20:49:01 +08:00
Haojun Liao c68c0eda79 fix(stream): fix bugs caused by refactor sm. 2023-10-20 16:27:39 +08:00
Haojun Liao 4feebffb05 refactor: add ref in log. 2023-10-20 15:59:43 +08:00
Haojun Liao c4268ca395 fix(stream): fix bugs caused by refactor. 2023-10-20 15:54:30 +08:00
Haojun Liao 3b8c85f632 fix(stream): fix bugs caused by refactor sm. 2023-10-20 14:19:57 +08:00
Haojun Liao d75948160d Merge branch 'main' into refact/streamsm 2023-10-20 11:10:19 +08:00
Haojun Liao 270a847809 fix(stream): fix bugs caused by refactor sm. 2023-10-20 10:23:48 +08:00
Haojun Liao 4d5d078fbe fix(stream): fix bugs caused by refactor. 2023-10-19 18:00:54 +08:00
Haojun Liao d5059826a8 fix(stream): fix bugs caused by refactor. 2023-10-19 17:59:04 +08:00
Haojun Liao c1cebae6ba fix(stream): fix error in stream. 2023-10-19 16:20:27 +08:00
Haojun Liao 402aefd95d refactor(stream): do some internal refactor. 2023-10-19 15:09:47 +08:00
slzhou 24436c8502 fix: tag scan support limit and remove slimit optimization 2023-10-19 11:40:10 +08:00
Haojun Liao f4caeca24a refactor(stream): add state machine to manage the state of stream tasks. 2023-10-19 10:34:20 +08:00
Haojun Liao 54ec679b58 refactor(stream): do some internal refactor. 2023-10-18 15:34:53 +08:00
Haojun Liao 2904cfd4d5 Merge branch 'main' into refact/streamsm 2023-10-18 10:29:09 +08:00
Haojun Liao 5115a1ac88
Merge pull request #23304 from taosdata/fix/TD-26771
double free
2023-10-18 10:09:17 +08:00
Haojun Liao df07443379
Merge pull request #23288 from taosdata/fix/liaohj
fix(stream):add more check for test cases.
2023-10-18 08:13:15 +08:00
liuyao afa44732e2 Merge branch 'main' of https://github.com/taosdata/TDengine into main 2023-10-17 14:49:30 +08:00
liuyao 5e0f9cb908 double free 2023-10-17 14:32:09 +08:00
Haojun Liao 64ed7e49a2 enh(stream): sm for stream tasks. 2023-10-17 13:47:55 +08:00
Haojun Liao 7b7ce10475 refactor(stream): do some internal refactor. 2023-10-17 11:23:04 +08:00
Haojun Liao 14035c763c refactor: do some internal refactor. 2023-10-17 09:57:13 +08:00
Haojun Liao fdb6ec1fa3 enh(stream): add parameter to limit the stream sink task. 2023-10-16 22:52:39 +08:00
liuyao 990d36654d release buff 2023-10-16 19:49:45 +08:00
Haojun Liao a1aa2c9e0c fix(stream):add more check for test cases. 2023-10-16 18:47:01 +08:00
Haojun Liao 582bedd4bb
Merge pull request #23277 from taosdata/fix/TD-26722
set fill history range
2023-10-16 17:38:49 +08:00
liuyao 4ba45abd01 set fill history range 2023-10-16 13:53:54 +08:00
Haojun Liao 67bee17e5e other: merge main. 2023-10-16 09:55:41 +08:00
Haojun Liao f90cf54714 fix(stream): fix error in creating update node trans. 2023-10-15 21:56:49 +08:00
Haojun Liao 6611f216ac enh(stream): add some logs. 2023-10-13 19:45:29 +08:00
Alex Duan 35fced8796
Merge pull request #23234 from taosdata/main_3_merge
other: merge main into 3.0
2023-10-12 07:48:20 -05:00
Haojun Liao 90f866352b
Merge pull request #23221 from taosdata/feat/TD-26052
fix:[TD-26671] judge if pointer is null to avoid core dump
2023-10-12 17:23:41 +08:00
Haojun Liao eb4449999f other: merge 3.0 2023-10-12 10:33:48 +08:00
wangmm0220 05c016b667 fix:[TD-26671] judge if pointer is null to avoid core dump 2023-10-11 13:55:54 +08:00
dapan1121 3ff3fe7477
Merge pull request #23181 from taosdata/enh/TD-26604
enh: support balance group leader on vgroup_id
2023-10-11 13:25:51 +08:00
Hongze Cheng ef94767758
Merge pull request #23213 from taosdata/FIX/TD-26664-3.0
enh: send rpc rsp on error of tmsgPutToQueue
2023-10-10 22:46:24 -05:00
wangmm0220 f7d1e0ea82 fix:[TD-26671] judge if pointer is null to avoid core dump 2023-10-11 11:08:14 +08:00
Haojun Liao 6982935df7
Merge pull request #23157 from taosdata/fix/liaohj
refactor(stream): fix bugs and do some internal refactor.
2023-10-11 10:30:16 +08:00
dapan1121 17e3b99bed
Merge pull request #23200 from taosdata/szhou/main/revert-create-table-sql
Revert "fix: add create table sql to audit log"
2023-10-11 08:52:53 +08:00
dapan1121 c5ec45ddb4
Merge pull request #23185 from taosdata/feat/TD-26639
feat: remove partition node for agg
2023-10-11 08:36:48 +08:00
Haojun Liao 1d4f0c8599
Merge pull request #23201 from taosdata/enh/TD-26646
Enh/td 26646
2023-10-10 22:59:37 +08:00
Benguang Zhao a9ed36e167 enh: send rpc rsp on error of tmsgPutToQueue 2023-10-10 16:53:15 +08:00
Haojun Liao 5f9b858fc1 other: merge main. 2023-10-10 15:38:46 +08:00
yihaoDeng b36163a197 add session iter 2023-10-10 15:12:21 +08:00
yihaoDeng 825341d90a add sess iter 2023-10-10 14:35:02 +08:00
wangjiaming0909 eea90507d4 feat: remove partition node for agg 2023-10-10 14:29:36 +08:00
Haojun Liao ba1690f0dd Merge remote-tracking branch 'origin/fix/liaohj' into fix/liaohj 2023-10-10 14:00:48 +08:00
Haojun Liao adf6f65d09 fix(stream): set initial version for fill-history task. disable reentry of scan-history task function. 2023-10-10 14:00:30 +08:00
Alex Duan 9da96ebf63
Merge pull request #23017 from taosdata/case/TD-26408-MAIN
fix: add case for lost data after  split vgroup (main)
2023-10-10 00:54:34 -05:00
Alex Duan e566027cef
Merge pull request #23019 from taosdata/case/TD-26408-3.0
fix: add case for lost data after split 3.0
2023-10-10 00:53:56 -05:00
yihaoDeng 6adf7532a8 add sess iter 2023-10-10 11:35:18 +08:00
shenglian zhou 6c30c4faab Revert "fix: add create table sql to audit log"
This reverts commit 658de2a04e.
2023-10-10 11:12:53 +08:00
yihaoDeng 7ac4ef5beb add sess iter 2023-10-10 10:41:46 +08:00
liuyao 26c87e5f41 fix mem leak 2023-10-10 10:26:26 +08:00
yihaoDeng 0fc6ffe6b6 change test case 2023-10-09 20:51:26 +08:00
yihaoDeng c6e9134cea add sess iter 2023-10-09 20:02:23 +08:00
Haojun Liao b0ef091430 fix(stream): retry when error occurs during timer. 2023-10-09 16:40:05 +08:00
Haojun Liao be0a2e4573 fix(stream): disable retrieving results during checkpoint procedure 2023-10-09 16:33:28 +08:00
dapan1121 7c7cf2b1aa enh: support balance group leader on vgroup_id 2023-10-09 15:46:41 +08:00
wade zhang 7c738cbe0c
Merge pull request #23168 from taosdata/feat/TS-4036-main
feat: alter local/dnode asynclog
2023-10-09 15:44:39 +08:00
Haojun Liao 8266c4ff77 fix(stream): remove invalid clear of rspmsg list. 2023-10-09 15:26:42 +08:00
Haojun Liao d87db2f829 fix(stream): fix the pause failure bug. 2023-10-09 14:48:11 +08:00
yihaoDeng 28b546a4ad fix mem leak 2023-10-09 14:25:57 +08:00
yihaoDeng be42143362 Merge branch '3.0' into case/TD-26408-3.0 2023-10-09 14:24:31 +08:00
yihaoDeng 3f9784f475 fix mem leak 2023-10-09 14:07:22 +08:00
Haojun Liao 74ff0c5b50 Merge branch 'main' into fix/liaohj 2023-10-09 10:14:53 +08:00
Haojun Liao ee6516f3c4 enh(stream): add trans to reset task status to avoid being frozen in checkpoint status due to doing checkpoint failure of partial tasks. 2023-10-09 10:13:53 +08:00
Haojun Liao 4b8cd3bccd fix(stream): not idle for sink task when no tokens are available. 2023-10-09 10:07:19 +08:00
Haojun Liao e9ce38e2b0
Merge pull request #23159 from taosdata/fix/TD-26602
init bloomfilter array
2023-10-08 18:56:05 +08:00
liuyao 1d952ca8ea rebuild session window 2023-10-08 18:27:05 +08:00
Shungang Li a7507d26b0 feat: alter local/dnode asynclog 2023-10-08 18:26:25 +08:00
wade zhang 8e0179b73e
Merge pull request #23142 from taosdata/FIX/TS-4096-main
enh: reserve half a buffer size at syncLogBufferInit
2023-10-08 16:00:38 +08:00
liuyao 1cbb8ef444 init bloomfilter array 2023-10-08 14:43:44 +08:00
yihaoDeng b5994b31e2 fix mem leak 2023-10-08 13:33:02 +08:00
liuyao ed8cad22cb Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TD-26174 2023-10-08 13:31:51 +08:00
yihaoDeng e3f18495e0 fix mem leak 2023-10-08 11:22:26 +08:00
Haojun Liao 23fb26798f fix(stream): sleep for 10ms 2023-10-07 19:47:49 +08:00
Haojun Liao e4e4c5a36e fix(stream): wait for a while when no available token. 2023-10-07 19:41:49 +08:00
Haojun Liao 45bb3f50d7 fix(stream): continue 2023-10-07 19:25:40 +08:00
liuyao 95ffe6fa23 stream recover 2023-10-07 19:24:21 +08:00
Haojun Liao 62cdcbc7e3 refactor: inc the dump batch. 2023-10-07 19:20:48 +08:00
Haojun Liao 4d6f143146 fix(stream): add missing refactor. 2023-10-07 19:18:26 +08:00
Haojun Liao ab17bfdf09 refactor: do some internal refactor. 2023-10-07 19:16:55 +08:00
Haojun Liao 0e8a8aabc1 fix(stream): check items in queue and qall, stead of only the queue items. 2023-10-07 19:16:25 +08:00
liuyao c088ee7f91 Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TD-26174 2023-10-07 19:13:07 +08:00
liuyao 1e323c0408 fix issue 2023-10-07 19:11:46 +08:00
liuyao 19bbf10579 fix issue 2023-10-07 17:59:53 +08:00
yihaoDeng 97fdcbc60b fix mem leak 2023-10-07 17:48:24 +08:00
liuyao 1aaf873134 fix issue 2023-10-07 17:43:50 +08:00
Haojun Liao d11c0a113c fix(stream): fix syntax error. 2023-10-07 14:56:09 +08:00