Commit Graph

29825 Commits

Author SHA1 Message Date
wangmm0220 d3659db2ff fix:[TD-28202]move tq timer to write thread in mnode 2024-01-11 19:22:54 +08:00
factosea 3ed63df082 fix case 2024-01-11 18:34:21 +08:00
Haojun Liao 404ae75178
Merge pull request #24429 from taosdata/fix/3_liaohj
fix(stream): add checkpoint status check.
2024-01-11 17:59:57 +08:00
Yihao Deng d3cfa97740 fix invalid read 2024-01-11 09:41:02 +00:00
wangmm0220 89ca3418af fix:[TD-28188]the epset of snode is error because epset is not initilized 2024-01-11 17:38:15 +08:00
Haojun Liao 9703018f56 fix(stream): add checkpoint status check. 2024-01-11 16:47:51 +08:00
Haojun Liao dc6187a2e3
Merge pull request #24426 from taosdata/fix/3_liaohj
refactor: do some internal refactor.
2024-01-11 16:47:05 +08:00
slzhou 3cea4fd2c7 fix: getNextTimeWindow use new time algorithm 2024-01-11 16:41:11 +08:00
wade zhang 69ba56feda
Merge pull request #24402 from taosdata/ENH/TD-28211-3.0
enh: let max num of concurrent msgs of snap replication be configurable
2024-01-11 16:38:53 +08:00
Yihao Deng b0f6709474 split sync/status channel 2024-01-11 07:30:39 +00:00
Yihao Deng 5a1510aa2f split sync/status channel 2024-01-11 07:30:03 +00:00
Yihao Deng 5e1a7c694b split sync/status channel 2024-01-11 07:23:46 +00:00
Haojun Liao d4fd544c74 refactor: remove sleep. 2024-01-11 15:18:11 +08:00
slzhou 7d46458bb7 fix: use slide start to calculate previous slide start 2024-01-11 14:50:14 +08:00
Yihao Deng 423fa76207 split sync/status channel 2024-01-11 06:01:06 +00:00
yihaoDeng 44146caa9a opt msg on mnd 2024-01-11 13:46:54 +08:00
Haojun Liao 5f7ce21530 refactor: do some internal refactor. 2024-01-11 11:59:29 +08:00
Haojun Liao 58694c67dd refactor: do some internal refactor. 2024-01-11 11:50:52 +08:00
Yihao Deng df235b0adf split sync/status channel 2024-01-11 03:22:34 +00:00
wangjiaming0909 686108050b fix: table merge scan return disordered rows 2024-01-11 09:57:35 +08:00
Haojun Liao f6c0649108 fix(stream): fix syntax error. 2024-01-11 09:53:19 +08:00
Haojun Liao bff0ad89a4 other: merge 3.0 2024-01-11 09:51:12 +08:00
Haojun Liao 1c562bd535 refactor: enable the restart of stream tasks. 2024-01-11 09:41:40 +08:00
54liuyao 3b36dbbe18 opt recover buff 2024-01-11 09:40:54 +08:00
Haojun Liao 0ab308ef79
Merge pull request #24418 from taosdata/fix/TD-28185
fix:[TD-28185]add pause & resume logic for snode
2024-01-11 09:40:49 +08:00
Haojun Liao 9294c8d4ee fix(stream): enable the hb to mnode for stream meta when it becomes the leader. 2024-01-11 09:20:34 +08:00
slzhou ab137a56f0 fix: more interval end calculation with slide-start/slide-end as anchor 2024-01-11 08:31:16 +08:00
slzhou b4b4400958 fix: recalcuate window ekey 2024-01-10 21:36:09 +08:00
wangmm0220 216830f8b4 fix:[TD-28185]add pause & resume logic for snode 2024-01-10 20:33:13 +08:00
Haojun Liao dcbe963d32 fix(stream): keep the previous status in stack object. 2024-01-10 19:19:53 +08:00
factosea c8fb8486ef fix: SColumnRefNode disable 2024-01-10 19:07:21 +08:00
wangmm0220 df69a89da2 fix:[TD-28185]add pause & resume logic for snode 2024-01-10 18:46:10 +08:00
Yihao Deng b5e5167b8f split sync/status channel 2024-01-10 09:57:08 +00:00
wangmm0220 27b63b721f fix:decode mqDataMsg error for the message with old version 2024-01-10 17:36:51 +08:00
slzhou ba2ba0a8cb fix: time window computation error 2024-01-10 16:19:20 +08:00
wangmm0220 02c7bdd4f0 fix:[TD-28032]fsdfasd 2024-01-10 14:57:16 +08:00
Yihao Deng 3f0236ec17 opt msg on mnode 2024-01-10 06:18:39 +00:00
Yihao Deng 2537adb728 opt msg on mnode 2024-01-10 06:00:44 +00:00
Haojun Liao b0202bb853 fix(tsdb): open reader during resume task for main reader after suspending reader. 2024-01-10 13:44:21 +08:00
Haojun Liao e8aea42498 fix(tsdb): open reader during resume task for main reader after suspending reader. 2024-01-10 13:42:36 +08:00
Benguang Zhao 485bad1ebd refact: use config syncSnapReplMaxWaitN instead 2024-01-10 11:31:00 +08:00
Haojun Liao 1b6d55616f fix(stream): fix syntax error. 2024-01-10 11:28:06 +08:00
Haojun Liao eac0d14868 fix(stream): add check when merging rows from files and buffer. 2024-01-10 11:02:44 +08:00
yihaoDeng 9dbddeed16 opt msg on mnd 2024-01-10 10:03:38 +08:00
Haojun Liao 9d0d0d9ddc Merge branch '3.0' into fix/3_liaohj 2024-01-10 09:57:46 +08:00
Haojun Liao 273e47a1fb
Merge pull request #24405 from taosdata/fix/optMsgOnMnd
opt msg on mnode
2024-01-10 09:43:48 +08:00
Haojun Liao 2b3ad002f5
Merge pull request #24401 from taosdata/fix/TD-28142-3.0
opti:[TD-28142]memory size if block num is too large
2024-01-10 09:40:07 +08:00
factosea d243308541 fix: colref 2024-01-10 09:04:40 +08:00
Haojun Liao dc0c5539a0 fix(stream): remove invalid timer controllers. 2024-01-10 08:48:49 +08:00
Haojun Liao 3508c9b2f4
Merge pull request #24379 from taosdata/fix/addTestCaseToStreamBackend
Fix/add test case to stream backend
2024-01-09 21:23:51 +08:00
dapan1121 9b49bdeba8
Merge pull request #24399 from taosdata/fix/TS-4422-3.0
fix: get expired user for each cluster
2024-01-09 19:35:36 +08:00
Yihao Deng 220cef4a61 opt msg on mnode 2024-01-09 11:02:10 +00:00
Benguang Zhao 7979d4532b enh: let max num of concurrent msgs of snap replication be configurable 2024-01-09 16:49:27 +08:00
Hongze Cheng 7fa06df958
Merge pull request #24395 from taosdata/fix/TD-28208
fix(tsdb/cache): destory brin block with fs loading
2024-01-09 16:31:41 +08:00
wangmm0220 6444af84e4 opti:[TD-28142]memory size if block num is too large 2024-01-09 16:28:58 +08:00
kailixu 404e17e677 fix: get expired user for each cluster 2024-01-09 16:18:55 +08:00
Minglei Jin d93b4f88b3 fix(tsdb/cache): destory brin block with fs loading 2024-01-09 15:23:15 +08:00
Hongze Cheng a518cba133
Merge pull request #24380 from taosdata/fix/TD-28134-3.0
fix: possible race condition
2024-01-09 09:47:01 +08:00
Haojun Liao f9d5c0d403 fix(stream): fix error in tq timer. 2024-01-09 09:13:53 +08:00
dapan1121 ad83e6439f
Merge pull request #24336 from taosdata/FIX/TD-28125
Fix: not use last row scan when select tbname and last
2024-01-09 08:40:15 +08:00
fullhonest 5bd29a413b Fix: not use last row scan when select tbname and last 2024-01-08 19:49:15 +08:00
Haojun Liao bbaaad6f1f fix(stream): add null ptr check. 2024-01-08 18:45:36 +08:00
Haojun Liao af9dc441b2 fix(stream): reset the saved value for fill-history task. 2024-01-08 18:40:06 +08:00
Haojun Liao 70c1e66959 fix(stream): release task after launch stream tasks. 2024-01-08 18:19:31 +08:00
Hongze Cheng 5e45ecd3fd fix: possible race condition 2024-01-08 16:46:07 +08:00
factosea 45ec9fcbc8 fix: create param node from function node 2024-01-08 16:43:57 +08:00
Yihao Deng 4c5441da7e refactor stream code 2024-01-08 08:38:16 +00:00
Yihao Deng 1c28f53525 refactor stream code 2024-01-08 08:28:00 +00:00
Yihao Deng 1eee7b44e0 fix crash found on 3.1 2024-01-08 07:31:35 +00:00
dapan1121 003e4a886d
Merge pull request #24360 from taosdata/szhou/fix/TD-28169
fix: sort error processing of out of space
2024-01-08 14:35:52 +08:00
dapan1121 6d8637fcf3
Merge pull request #24364 from taosdata/fix/xsren/TD-28165/wildcard2
fix: wildcard character in both target and pattern
2024-01-08 14:34:13 +08:00
Haojun Liao 3bcd038b7d refactor: not reload info from disk when trying to restart stream tasks. 2024-01-08 14:04:36 +08:00
factosea 8c3fe7cc70 fix: SColumnRefNode transfer to SelectFunction's param 2024-01-08 11:41:58 +08:00
Haojun Liao f7ab55fb71
Merge pull request #24342 from taosdata/fix/TD-28155
fix:[TD-28155] set consumer lost if all current topic is 0
2024-01-08 11:39:16 +08:00
Haojun Liao 275e2d6f94 refactor: do some internal refactor. 2024-01-08 11:34:47 +08:00
Haojun Liao bb9edde79e fix(stream): add some logs. 2024-01-08 11:33:54 +08:00
wade zhang 399587511a
Merge pull request #24348 from taosdata/fix/TD-28073-3.0
fix/TD-28073
2024-01-08 09:59:35 +08:00
factosea c5932c9d1c fix: wildcard character in both target and pattern 2024-01-08 01:13:53 +08:00
slzhou 9646091492 fix: sort error due to out of space 2024-01-07 16:18:24 +08:00
Haojun Liao a024fe960c fix(stream): fix deadlock. 2024-01-07 14:53:17 +08:00
Haojun Liao 29219ba9f4 fix(stream): add task number check. 2024-01-07 01:32:50 +08:00
Haojun Liao 5e32aea1f9 fix(stream): jump out of loop when downstream is blocking. 2024-01-07 00:27:18 +08:00
Haojun Liao 02f6c971fd fix(stream): check for not ready task when rsp returned. 2024-01-06 19:43:39 +08:00
Haojun Liao cfda97beef refactor: disable commit temp 2024-01-06 15:27:48 +08:00
Haojun Liao 23341e1bdf refactor: opt perf by avoid save tasks during restoring 2024-01-05 22:58:43 +08:00
Haojun Liao 445605ed22 refactor: do some internal refactor. 2024-01-05 22:35:56 +08:00
Haojun Liao 522e688387 fix(stream): check if in restart procedure in call back. 2024-01-05 22:16:58 +08:00
wangmm0220 f2a1d24ab1 fix:[TD-28155] set consumer lost if all current topic is 0 2024-01-05 19:28:40 +08:00
Haojun Liao 2386f842fb enh(stream): remove sleep to opt perf. 2024-01-05 18:46:15 +08:00
Haojun Liao 33253cbb54 fix(stream): add null ptr check. 2024-01-05 18:13:35 +08:00
Haojun Liao 0c4b91dc72 enh(stream): start task async. 2024-01-05 17:55:39 +08:00
54liuyao 0b9e3c9871 fix stream state buff issue 2024-01-05 16:20:55 +08:00
dmchen 8ddff2eecb fix/TD-28073 2024-01-05 07:02:16 +00:00
Haojun Liao 1912de9b49 enh(stream): scan wal by using timer to trigger it. 2024-01-05 14:49:33 +08:00
dapan1121 f6c366ec53
Merge pull request #24298 from taosdata/fix/TD-28078-3.0
fix: check in client when create index
2024-01-05 14:48:48 +08:00
wade zhang a4f68411ed
Merge pull request #24332 from taosdata/ENH/TD-25112-3.0
enh: use learner in split vgroup
2024-01-05 14:26:27 +08:00
wade zhang cab9a243de
Merge pull request #24334 from taosdata/ENH/TD-26498-3.0
enh: allow to drop an empty dnode, no matter online or not
2024-01-05 14:16:50 +08:00
wade zhang 6239fe7a95
Merge pull request #24339 from taosdata/FEAT/TS-3816-3.0
enh: restore sync log store from snap on fsm state incomplete
2024-01-05 14:15:22 +08:00
kailixu d3aee612e0 chore: code optimization 2024-01-05 13:08:16 +08:00
kailixu 1169fe357a feat: uniq grant 2024-01-05 00:53:38 +08:00
kailixu 81d8b9b98b test: add test case for create index 2024-01-05 00:35:29 +08:00
kailixu 6bac747ab9 Merge branch '3.0' into fix/TD-28078-3.0 2024-01-04 23:47:41 +08:00
Benguang Zhao a811a60ad4 enh: restore sync log store from snap on fsm state incomplete 2024-01-04 20:15:17 +08:00
Haojun Liao 0c8d5e3586 fix(stream): fix syntax error. 2024-01-04 19:20:50 +08:00
Haojun Liao 356b7093f5 fix(stream): fix syntax error. 2024-01-04 19:18:10 +08:00
Haojun Liao 14e90eb16e fix(stream): fix syntax error. 2024-01-04 19:15:51 +08:00
Haojun Liao 4df83e92cd fix(stream): fix syntax error. 2024-01-04 19:14:24 +08:00
Haojun Liao 6286e42f5c refactor: do some internal refactor. 2024-01-04 19:11:50 +08:00
Haojun Liao 33f698e926 fix(stream): remove invalid assert and add check for task status before launching related fill-history task. 2024-01-04 19:09:45 +08:00
Hongze Cheng df74b2d755
Merge pull request #24284 from taosdata/fix/TD-27988
fix: remove useless code
2024-01-04 19:03:45 +08:00
wangmm0220 bd64a78094 fix:[TD-28155] set consumer lost if all current topic is 0 2024-01-04 18:53:37 +08:00
Haojun Liao 6d37e596ec refactor: do some internal refactor. 2024-01-04 18:47:49 +08:00
Haojun Liao c494252002 fix(stream): record the related fill-history task failure. 2024-01-04 17:44:05 +08:00
Benguang Zhao b85f36bcea enh: allow to drop an empty dnode, no matter online or not 2024-01-04 12:00:49 +08:00
Hongze Cheng 13834802ef
Merge pull request #24269 from taosdata/FIX/TD-28101-3.0
enh: send rsp msg on rejecting snap replication due to smaller term
2024-01-04 10:15:09 +08:00
Benguang Zhao f4ad4ea998 enh: use learner in split vgroup 2024-01-04 10:01:05 +08:00
wade zhang 5aae347566
Merge pull request #24330 from taosdata/fix/TS-4419
fix: refactor logdebugs
2024-01-04 09:58:51 +08:00
dapan1121 670317ccd7
Merge pull request #24053 from taosdata/enh/3.0/TD-26813
enh: support group by tag/tbname to list empty groups
2024-01-04 09:08:03 +08:00
Bob Liu 860146d425 initRemainGroups 2024-01-03 23:59:48 +08:00
Haojun Liao 1e3aad8883 refactor: do some internal refactor. 2024-01-03 23:57:33 +08:00
Haojun Liao 74df121cf5 fix(stream): fix the deadlock. 2024-01-03 22:29:46 +08:00
wangmm0220 df70a6ef57 fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line 2024-01-03 21:11:26 +08:00
factosea 8dc2a6bbd9 fix: orderby 2024-01-03 20:43:23 +08:00
Shungang Li de631e20a5 fix: refactor logdebugs 2024-01-03 19:57:22 +08:00
wangmm0220 b200e6807f fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line 2024-01-03 19:44:30 +08:00
Haojun Liao 3fea717373 fix(stream): discard the orphan tasks. 2024-01-03 19:28:49 +08:00
Haojun Liao b06ccc0ca7 fix(stream): cleanup the checkpoint trans & task info in execInfo 2024-01-03 19:18:06 +08:00
wangmm0220 317f0c6a39 fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line 2024-01-03 18:48:54 +08:00
factosea b6b2a41d83 fix: columnrefnode 2024-01-03 18:30:57 +08:00
Haojun Liao 4399867e14 fix(stream): fix the not running bug. 2024-01-03 18:28:23 +08:00
Haojun Liao 4138692cea fix(stream): scan wal data files. 2024-01-03 18:16:18 +08:00
Haojun Liao 185fa75376 enh(stream): add task into timer to be idle during exec when the corresponding output queue is full. 2024-01-03 17:59:42 +08:00
Bob Liu b818faaa5e remainGroups 2024-01-03 17:51:27 +08:00
dapan1121 f0fbffa772
Merge pull request #24301 from taosdata/fix/3.0/TD-28104
fix: last table scan reported invalid param when col was dropped which
2024-01-03 15:47:33 +08:00
Haojun Liao 284ef7d085 fix(stream): remove the related checkpoint trans when trying to drop stream. 2024-01-03 14:44:04 +08:00
Haojun Liao a2e85c44c2
Merge pull request #24228 from taosdata/fix/3_liaohj
refactor: remove stream-scan-history event for stream task.
2024-01-03 14:43:20 +08:00
Benguang Zhao de5f9b351f enh: use learner in redistribute vgroup 2024-01-03 11:49:05 +08:00
Haojun Liao 453d3e8a30 fix(stream): fix dead lock on windows. 2024-01-03 10:50:38 +08:00
wangmm0220 ab262550d1 fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line 2024-01-03 10:37:05 +08:00
wangmm0220 9ba2f71487 fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line 2024-01-03 10:16:43 +08:00
Haojun Liao 6c7683dba6
Merge pull request #24310 from taosdata/fix/crash_stream
fix(tsdb): check if stt blocks are clean before building data blocks.
2024-01-02 21:30:28 +08:00
factosea 34e62d7fc0 fix: columanRefNode illegal type conversion 2024-01-02 20:22:15 +08:00
wangmm0220 8add4dc177 fix:[TD-28032]concat subtable and hash val as new subtable name to avoid data from multi time line write to one time line 2024-01-02 18:37:29 +08:00
Haojun Liao 5bbf12c2c9 fix(tsdb): check if stt blocks are clean before building composed data blocks. 2024-01-02 18:35:17 +08:00
Haojun Liao 2387d5bade refactor: do some internal refactor. 2024-01-02 17:10:12 +08:00
Haojun Liao 29afc2ad6a fix(stream):add jump condition for loop. 2024-01-02 15:48:08 +08:00
Bob Liu 85ba9a4a5f remainGroups 2024-01-02 15:45:03 +08:00
Haojun Liao 039aef3471
Merge pull request #24300 from taosdata/fix/TD-28110
fix:error msg is not specific in create stream
2024-01-02 14:53:44 +08:00
54liuyao afc2a346e5 reset update info 2024-01-02 14:23:41 +08:00
dapan1121 06e3d8df1d
Merge pull request #24282 from taosdata/fix/3.0/TS-4411
fix: fill prev not working when desc fill
2024-01-02 13:07:21 +08:00
Haojun Liao e7a0044502 Merge branch '3.0' into fix/3_liaohj 2024-01-02 13:02:55 +08:00
dapan1121 5569f6a959
Merge pull request #24288 from taosdata/FIX/TD-27939
Fix error about sub query is empty when where 1=2
2024-01-02 11:50:44 +08:00
Haojun Liao 4368bfb20a fix(stream): fix dead lock. 2024-01-02 11:40:29 +08:00
dapan1121 4dc31987a4
Merge pull request #24246 from taosdata/FIX/TD-27989
Fix: taosd crashed at tpercentile.c 382,377
2024-01-02 11:10:42 +08:00
Haojun Liao b3d8f4e9d6 fix(stream): fix a typo. 2024-01-02 10:39:01 +08:00
Haojun Liao 59642c674d
Merge pull request #24254 from taosdata/fix/TS-3491-3.0
fix:[TS-4391] rebalance cnt always 1 if msg lost
2024-01-02 10:34:41 +08:00
Haojun Liao 3dcdad4464 Merge remote-tracking branch 'origin/fix/3_liaohj' into fix/3_liaohj 2024-01-02 10:33:46 +08:00
Haojun Liao d217412691 fix(stream): avoid race condition in starting threads. 2024-01-02 10:33:25 +08:00
wangjiaming0909 be0d35a5af fix: last table scan reported invalid param when col was dropped which
should report invalid col
2024-01-02 10:20:04 +08:00
Haojun Liao d5a9d0de46
Merge pull request #24272 from taosdata/mark/3.0
fix:set error msg if build consumer error
2024-01-02 10:15:02 +08:00
54liuyao c787535693 fix session state issue 2024-01-02 10:11:22 +08:00
wangmm0220 0e9a1b22ed fix:error msg is not specific in create stream 2024-01-02 10:10:44 +08:00
fullhonest e79516ade3 Fix TD-27939: error for sub query is empty when where 1=2 2024-01-02 10:02:30 +08:00
kailixu ecf3a7b6d3 fix: code optimization 2024-01-02 00:28:30 +08:00
kailixu 0d26c186f0 chore: code optimization 2024-01-02 00:23:19 +08:00
kailixu 40205541a6 fix: check in client when create index 2024-01-02 00:19:23 +08:00
Alex Duan 28238fa7dc coverage: no call function with BUILD_NO_CALL MACRO define 2023-12-31 18:29:37 +08:00
Bob Liu 673d3bc376 arrangeTableGroup 2023-12-31 13:15:05 +08:00
Alex Duan 1debd50a57
Merge pull request #24290 from taosdata/case/TD-18808-3.0
s3 with minio add test case  server on 192.168.1.52
2023-12-30 20:47:07 +08:00
Alex Duan 1e8244f3c6 feat: add s3 minio ci case 2023-12-30 10:31:15 +08:00
Haojun Liao 83172f4580
Merge pull request #24286 from taosdata/fix/crash_stream
fix(stream): update the stream error code.
2023-12-29 22:39:24 +08:00
Haojun Liao 7abeb5a27a fix(stream): update the stream error code. 2023-12-29 17:44:10 +08:00
Haojun Liao 8ac02adc0b refactor: do some internal refactor. 2023-12-29 17:42:23 +08:00
wangmm0220 d158ca74d8 fix:[TS-4391] rebalance cnt always 1 if msg lost 2023-12-29 17:22:27 +08:00
Bob Liu 7e1d59c565 sort 2023-12-29 16:22:41 +08:00
Hongze Cheng 7cb12db8ce remove more useless code 2023-12-29 15:20:27 +08:00
wangjiaming0909 90a8fe5581 fix: fill prev not working when desc fill 2023-12-29 15:08:56 +08:00
wangmm0220 c83989754f fix:[TS-4391] rebalance cnt always 1 if msg lost 2023-12-29 14:09:49 +08:00
wangmm0220 b58a23df49 fix:[TS-4391] rebalance cnt always 1 if msg lost 2023-12-29 13:57:13 +08:00
Benguang Zhao 68cb86602e fix: reuse cid with fs eid updated in tsdbFSetRAWWriteFileDataBegin 2023-12-29 11:49:57 +08:00
fullhonest 0a0f1a9d22 Fix TD-27989 2023-12-29 11:33:47 +08:00
Haojun Liao 50ce4f4455
Merge pull request #24257 from taosdata/fix/TD-28091
reset datablock window info
2023-12-29 09:04:41 +08:00
Haojun Liao a662f6d63f
Merge pull request #24262 from taosdata/fix/TD-28099
reset unclose window info
2023-12-29 09:04:31 +08:00
dapan1121 55b7bce8b7
Merge pull request #24256 from taosdata/szhou/fix/TD-28019
fix: change the result schema
2023-12-29 08:40:53 +08:00
Bob Liu e2b61a55fc refactor 2023-12-29 01:40:17 +08:00
Bob Liu 9f8f69a791 adjust 2023-12-28 21:54:16 +08:00
Benguang Zhao baa7f9c895 enh: adjust error msg as warn for not ready to propose etc 2023-12-28 17:29:49 +08:00
Benguang Zhao d83f85bf26 enh: send rsp msg on rejecting snap replication due to smaller term 2023-12-28 17:26:46 +08:00
wangmm0220 53ce344b36 fix:set error msg if build consumer error 2023-12-28 17:09:52 +08:00
Bob Liu 424ab1bbe3 support table merge scan 2023-12-28 16:18:38 +08:00
54liuyao 51cd8e9fb7 reset unclose window info 2023-12-28 15:34:13 +08:00
54liuyao 448b7c939f reset datablock window info 2023-12-28 11:09:38 +08:00
54liuyao f1304680c5 log 2023-12-28 11:09:03 +08:00
54liuyao c124bcf52f check block rows 2023-12-28 11:09:03 +08:00
slzhou 659c0a831e fix: change the result schema 2023-12-28 10:25:37 +08:00
Bob Liu a5f88a86e9 adjust 2023-12-28 09:45:01 +08:00
54liuyao 60271605ff Merge branch '3.0' of https://github.com/taosdata/TDengine into 3.0 2023-12-28 08:51:59 +08:00
Bob Liu abed781bd3 opt 2023-12-27 23:15:11 +08:00
Haojun Liao 1659164926 fix(stream): remove invalid checkpoint id check. 2023-12-27 23:00:18 +08:00
Haojun Liao 646f24659e fix(stream): fix syntax error. 2023-12-27 22:58:08 +08:00
Haojun Liao 7eb0e42bb9 fix(stream): handle error when checkpoint is interrupted by nodeUpdate. 2023-12-27 22:57:58 +08:00
Bob Liu d795798648 count state 2023-12-27 21:37:00 +08:00
Hongze Cheng 90645cbc77
Merge pull request #24220 from taosdata/fix/TD-27988
fix: remove useless code
2023-12-27 21:23:26 +08:00
wangmm0220 10e86fc733 fix:[TS-4391] rebalance cnt always 1 if msg lost 2023-12-27 19:25:08 +08:00
Hongze Cheng 2ada7d455e
Merge pull request #24236 from taosdata/fix/TD-28061
fix(tsdb/cache): erase entry from lru if deleted
2023-12-27 18:13:16 +08:00
54liuyao 6e761232b2 Merge branch '3.0' of https://github.com/taosdata/TDengine into 3.0 2023-12-27 15:57:53 +08:00
Bob Liu 158c5996df adjust case 2023-12-27 15:51:36 +08:00
wade zhang 0f7ad90845
Merge pull request #24227 from taosdata/FEAT/TD-27125-3.0
enh: retry on fsm commit when rpc out of memory in syncFsmExecute
2023-12-27 14:37:31 +08:00
54liuyao 382569591f log 2023-12-27 14:01:38 +08:00
54liuyao a46c921f68 check block rows 2023-12-27 11:29:03 +08:00
dapan1121 8448021780
Merge pull request #24232 from taosdata/fix/xsren/TD-28056/wildcard
fix: like wildcard match
2023-12-27 09:58:58 +08:00
Bob Liu 86351d5487 check count & window 2023-12-27 01:05:04 +08:00
Bob Liu 42f9d54a70 adjust 2023-12-27 00:28:42 +08:00
Bob Liu 3faf1514f4 doGroupedTableScan 2023-12-26 20:47:15 +08:00
Haojun Liao e553b84904 fix(stream): fix syntax error. 2023-12-26 19:16:49 +08:00
Haojun Liao 5592e11235 fix(stream): handle error when checkpoint is interrupted by nodeUpdate. 2023-12-26 19:02:52 +08:00
54liuyao ccf861dec8 Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/3_liaohj 2023-12-26 18:36:18 +08:00
54liuyao e2564a6189 fix issue 2023-12-26 18:35:49 +08:00
Haojun Liao 130f57859f
Merge pull request #24234 from taosdata/fix/TS-4403_30
fix tag index double free
2023-12-26 18:01:01 +08:00
wade zhang 1a215daefa
Merge pull request #24176 from taosdata/FIX/TD-27916-3.0
enh: demarcate top and bottom halves of task trans execution
2023-12-26 18:00:41 +08:00
Minglei Jin 2ba586513f fix(tsdb/cache): erase entry from lru if deleted 2023-12-26 16:41:33 +08:00
Yihao Deng 40aa5f697f fix tag index double free 2023-12-26 07:21:02 +00:00
dapan1121 b9ae472ad1
Merge pull request #24212 from taosdata/szhou/fix/TD-28019
fix: change compact rsp first column name
2023-12-26 15:06:17 +08:00
Yihao Deng dc01625ea1 fix tag index double free 2023-12-26 06:52:33 +00:00
factosea 1aae0e52e3 fix: like wildcard match 2023-12-26 14:48:05 +08:00
Haojun Liao b74e98b25c fix(stream): set the correct split timestamp for session/state window. 2023-12-26 14:17:46 +08:00
Benguang Zhao 0e6ea7af71 enh: check snapshot begin index for unexpected change in syncNodeOnSnapshotBegin 2023-12-26 10:54:40 +08:00
Bob Liu 2c9fa56e9c calcNeedCountEmpty 2023-12-26 10:24:50 +08:00
54liuyao 68be2dc534 Merge branch '3.0' of https://github.com/taosdata/TDengine into 3.0 2023-12-26 09:03:28 +08:00
Haojun Liao 62cfcefbb0 refactor: remove stream-scan-history event for stream task. 2023-12-26 00:34:04 +08:00
Haojun Liao 68795ecf35
Merge pull request #24225 from taosdata/fix/3_liaohj
fix(stream): handle the remaining event when restore from halt.
2023-12-25 22:52:25 +08:00
Benguang Zhao 7b967ffdc6 enh: retry on fsm commit when rpc out of memory in syncFsmExecute 2023-12-25 20:34:38 +08:00
54liuyao ac3c76f608 init dummy function 2023-12-25 19:38:20 +08:00
Haojun Liao f14c3b93c1 refactor: do some internal refactor. 2023-12-25 18:22:36 +08:00
Hongze Cheng a7c8563c06 fix: remove useless code 2023-12-25 16:13:30 +08:00
dapan1121 7da93155aa
Merge pull request #24185 from taosdata/szhou/fix/TD-27899
fix: BI support is moved to open source version
2023-12-25 15:27:37 +08:00
Haojun Liao bcc57e0644
Merge pull request #24207 from taosdata/fix/3_liaohj
fix(stream): add async call restart, instead of sync wait, and fix several deadlock.
2023-12-25 13:56:42 +08:00
Haojun Liao 60977d56bd refactor: set attribute only on Linux 2023-12-25 12:47:16 +08:00
Bob Liu 15694df001 adjust 2023-12-25 11:54:10 +08:00
wade zhang a4f7ee6fb5
Merge pull request #24158 from taosdata/fix/TD-27977
fix: dynamic cfg resetlog
2023-12-25 11:29:56 +08:00
Haojun Liao e5087f6e23 fix(tsdb): fix invalid delete check. 2023-12-25 10:40:36 +08:00
slzhou 1beb3347fa fix: change compact rsp first column name 2023-12-25 10:18:19 +08:00
wade zhang 40994c3fbd
Merge pull request #24174 from taosdata/FIX/TD-28001-3.0
enh: protect syncNodeRestore with log buffer mutex
2023-12-25 10:08:43 +08:00
wade zhang 1fc7a1a72e
Merge pull request #24128 from taosdata/FEAT/TD-27125-3.0
enh: protect processing of snap preparation rsp with sender buf mutex
2023-12-25 10:08:25 +08:00
Haojun Liao 00fac852e8 fix(tsdb): fix invalid delete check. 2023-12-25 09:55:24 +08:00
Benguang Zhao 7edfbf8023 fix: set commit log for mndAddCompactDetailToTran 2023-12-25 09:47:17 +08:00
Benguang Zhao 4f29500f74 fix: set commit log for mndDropSubByTopic 2023-12-25 09:46:55 +08:00
Haojun Liao 0877e0bfad other: merge 3.0 2023-12-25 09:13:31 +08:00
Bob Liu da0ecc18b9 test 2023-12-25 02:51:52 +08:00
Bob Liu 52c244d9ec adjust 2023-12-24 23:48:37 +08:00
Haojun Liao cd85dae3fd fix(stream): fix the dead lock. 2023-12-24 23:30:00 +08:00
Haojun Liao bf895fadcb fix(stream): fix invalid read. 2023-12-24 03:05:29 +08:00
Haojun Liao 30498a4028 refactor: do some internal refactor. 2023-12-24 02:24:46 +08:00
Bob Liu c9b69316c1 calcNeedCountEmpty 2023-12-24 01:19:16 +08:00
Haojun Liao 25f798e42f fix(stream): record the start failure tasks 2023-12-23 23:29:30 +08:00
Alex Duan 659acfd5f3
Merge pull request #24196 from taosdata/coverage/alex
coverage: remove tfunctionInt.c
2023-12-23 16:39:49 +08:00
Haojun Liao c61203b55a fix: fix deadlock. 2023-12-23 16:37:21 +08:00
Haojun Liao 8a714db17d fix: fix deadlock. 2023-12-23 15:33:50 +08:00
Haojun Liao 5c1ff76082 fix(stream): set rwlock attr. 2023-12-23 00:58:52 +08:00
Haojun Liao 66bdace9eb fix(stream): check rsp. 2023-12-23 00:09:55 +08:00
Haojun Liao 80604ec8e2 fix(stream): init rwlock. 2023-12-22 23:31:51 +08:00
Bob Liu ef5b5786b3 adjust 2023-12-22 18:14:26 +08:00
Bob Liu e3098accc4 support count empty table 2023-12-22 18:14:26 +08:00
Haojun Liao b175a4b7b3 refactor(stream): async stop tasks, and do some internal refactor. 2023-12-22 17:56:16 +08:00
fullhonest e13b3b9ceb Fix TD-27989: percentile crash 2023-12-22 17:51:16 +08:00
Alex Duan a71fabb24f coverage: remove tfunctionInt.c 2023-12-22 17:50:55 +08:00
dapan1121 709b7f4683
Merge pull request #24181 from taosdata/fix/TD-27967_TD-28004
fix: cache scan heap overflow and forbid DDD for to_char in windows
2023-12-22 16:54:46 +08:00
Shungang Li 212c1ebb3c udpate test case test_hot_refresh_configurations 2023-12-22 16:15:47 +08:00
Haojun Liao 7ce545bcd4 refactor: refactor the lock type. 2023-12-22 16:14:49 +08:00
Benguang Zhao 2de6d6c81d enh: add TSDB_CODE_MND_TRANS_CTX_SWITCH 2023-12-22 16:06:59 +08:00
Haojun Liao dce0a6c74a fix(stream): remove invalid assert 2023-12-22 15:24:37 +08:00
Haojun Liao e91afa7df2 fix(stream): fix deadlock. 2023-12-22 14:51:04 +08:00
Haojun Liao 67edc29a65
Merge pull request #24179 from taosdata/fix/TD-27957-30
fix snode crash
2023-12-22 14:41:41 +08:00
Haojun Liao 90898a16e0 refactor: do some internal refactor. 2023-12-22 13:57:15 +08:00
Hongze Cheng 02bb9e90d2
Merge pull request #24189 from taosdata/fix/TD-27974
fix(tsdb/cache): prepend ts col to load stt
2023-12-22 13:53:15 +08:00
slzhou 7dd6cb4227 fix: move bi to community version 2023-12-22 13:17:25 +08:00
dapan1121 ceedd5b051
Merge pull request #24170 from taosdata/szhou/fix/TS-4382
fix: the pre-allocated column has no data to copy
2023-12-22 12:31:07 +08:00
Minglei Jin 16ad59fb18 fix(tsdb/cache): prepend ts col to load stt 2023-12-22 12:14:27 +08:00
Yihao Deng f557d86609
Merge branch '3.0' into fix/initBackendHashmutex 2023-12-22 10:51:54 +08:00
Hongze Cheng 46211258b3
Merge pull request #24173 from taosdata/fix/TD-27974
fix(tsdb/cache): plus 1 to nCols to load stt data
2023-12-22 09:43:20 +08:00
Haojun Liao c9475060de fix(stream): fix race condition. 2023-12-22 09:34:49 +08:00
Haojun Liao 0fab9a1827 other: fix syntax error. 2023-12-22 00:29:49 +08:00
wangjiaming0909 153221e1d6 fix: cache scan heap overflow and forbid DDD for to_char in windows 2023-12-21 19:46:33 +08:00
kailixu 3005ab1953 chore: more code 2023-12-21 19:45:09 +08:00
Haojun Liao 84583580e2 fix(stream): transfer the checkpoint trans id. 2023-12-21 19:12:49 +08:00
yihaoDeng 913fda4a36 fix snode crash 2023-12-21 18:52:25 +08:00
Haojun Liao 949ff6b18c
Merge pull request #24168 from taosdata/fix/TD-27979
fix:[TD-27979] init mutux
2023-12-21 18:38:02 +08:00
Minglei Jin 9d3eb02f3c fix(tsdb/cache): plus 1 to nCols to load stt data 2023-12-21 17:53:44 +08:00
Benguang Zhao 4137a44fd0 enh: protect syncNodeRestore with log buffer mutex 2023-12-21 17:49:20 +08:00
slzhou 094c6cdfb4 fix: the pre-allocated column has no data to copy 2023-12-21 16:31:35 +08:00
Haojun Liao 2acc8423c5 fix(stream): send msg to mnode before closing all tasks. 2023-12-21 16:00:50 +08:00
wangmm0220 13851a60a4 fix:[TD-27979] init mutux 2023-12-21 15:26:41 +08:00
Alex Duan 1fa6cb8f69 coverage: isRowEntryCompleted had been called 5200w hits 2023-12-21 15:10:21 +08:00
Alex Duan 9d4a75b0be coverage: vnodeSrv.c tmsg.c trow.c 2023-12-21 14:22:22 +08:00
Alex Duan b0247f649b coverage : comment trow.c 2023-12-21 13:41:49 +08:00
kailixu 47fedce263 chore: more code 2023-12-21 12:11:00 +08:00
Haojun Liao 71f6d9f06f fix(stream): handle the case that recvs drop msg twice. 2023-12-21 11:52:45 +08:00
Haojun Liao 8a8ddf5699 fix(stream): record the checkpoint failure when nodeEp changed. 2023-12-21 10:30:44 +08:00
Benguang Zhao 572368703d enh: ensure mndTransProcessRsp invoked in mnode-write thread 2023-12-21 09:33:56 +08:00
Haojun Liao 32ce4b6a4c fix(stream): fix race condition. 2023-12-20 23:12:59 +08:00
Haojun Liao ad5d78a6ca fix(stream): fix deadlock. 2023-12-20 19:12:47 +08:00
Haojun Liao 64eee4bbd2 fix(stream): add conflict check for nodeUpdate 2023-12-20 19:06:32 +08:00
Shungang Li 4906243115 fix: dynamic cfg resetlog 2023-12-20 18:32:23 +08:00
Haojun Liao 849aaf8d4f fix(stream): avoid dead lock. 2023-12-20 18:07:53 +08:00
yihaoDeng d6297e26ce init backend mutex 2023-12-20 16:56:12 +08:00
dapan1121 cd044137a0
Merge pull request #24130 from taosdata/fix/3.0/TD-27945
fix: session window block row index overflow
2023-12-20 16:13:47 +08:00
dapan1121 e90fe43f93
Merge pull request #24083 from taosdata/enh/xsren/TD-27847
enh: call fetch_rows in taos_query_a callback
2023-12-20 16:12:31 +08:00
Haojun Liao 43fb7cf14a other: add log info. 2023-12-20 16:04:20 +08:00
Haojun Liao 1a8583887f fix(stream): remove clear backendcache. 2023-12-20 15:35:43 +08:00
Haojun Liao a0d1933134
Merge pull request #24113 from taosdata/mark/3.0
opti:logic in parse raw line & make log more specific
2023-12-20 15:25:26 +08:00
Haojun Liao d25a323a4c fix(stream): record the launch failure. 2023-12-20 13:55:12 +08:00
wangmm0220 1f70f51ac8 fix:sdb maxId should use int64* instead of int32* 2023-12-20 11:20:41 +08:00
Haojun Liao 94b260a1f9 refactor: do some internal refactor. 2023-12-20 10:29:04 +08:00
Haojun Liao 81d8b2434f refactor: do some internal refactor. 2023-12-20 10:25:31 +08:00
Haojun Liao 541967e99e refactor: do some internal refactor. 2023-12-20 10:24:03 +08:00
Benguang Zhao e06f355143 enh: improve logging msg of mndPostMgmtCode 2023-12-19 20:16:33 +08:00
Benguang Zhao f7ab8e99b5 enh: demarcate top and bottom halves of task trans execution to ensure a consistent order 2023-12-19 19:52:11 +08:00
Haojun Liao 2de0f6e971 test(stream): lock the update procedure. 2023-12-19 18:56:15 +08:00
Haojun Liao 92045f5485 fix(stream): add snode check, and handle the task status reset from checkpoint when it is in the snode. 2023-12-19 18:34:30 +08:00
wade zhang 8bbf03a695
Merge pull request #24116 from taosdata/fix/release-mem-check-3.0
release mem check
2023-12-19 18:13:53 +08:00
kailixu 1f5384ad40 feat: support uniq active code 2023-12-19 18:02:53 +08:00
Haojun Liao 17e9e84aa9 Merge branch '3.0' into fix/3_liaohj 2023-12-19 16:43:08 +08:00
Haojun Liao fee198f9ad refactor: do some internal refactor. 2023-12-19 16:21:11 +08:00
wangjiaming0909 ad24c03538 fix: session window block row index overflow 2023-12-19 14:31:13 +08:00
Benguang Zhao 4c13dee721 enh: protect processing of snap preparation rsp with sender buf mutex 2023-12-19 12:49:48 +08:00
wangmm0220 84d18005f2 fix:add control for raw data in schemaless 2023-12-19 11:34:15 +08:00
Haojun Liao ec3183b6a8 other: merge 3.0 2023-12-18 23:16:37 +08:00
Haojun Liao 612b50c4cd
Merge pull request #24097 from taosdata/fix/TD-27834
fix stream backend crash when transfer
2023-12-18 23:13:08 +08:00
Haojun Liao 579366ec00
Merge pull request #24121 from taosdata/fix/liaohj
other: merge main into 3.0
2023-12-18 23:11:36 +08:00
wangmm0220 ef621a06a7 opti:logic in parse raw line & make log more specific 2023-12-18 19:21:02 +08:00
Haojun Liao e734569de0 fix(stream): fix dead lock. 2023-12-18 18:42:57 +08:00
Haojun Liao bba5a4f08b other: merge main into 3.0 2023-12-18 18:26:42 +08:00
Minglei Jin 64378be7f4 fix(tsdb/cache): fix buffer-overflow with column adding 2023-12-18 18:06:40 +08:00
dmchen 19637fd148 release mem check 2023-12-18 09:32:31 +00:00
kailixu 70006bb711 feat: support alter cluster 2023-12-18 16:34:31 +08:00
Haojun Liao ea6e78cbaa fix(stream): add async call restart, instead of sync wait. 2023-12-18 16:33:44 +08:00
wade zhang 4cac96d2df
Merge pull request #24111 from taosdata/fix/TD-27845
fix(tsdb/cache): use int64_t instead of uint64_t for stt verRange
2023-12-18 16:27:18 +08:00
Haojun Liao 79672f8e5f
Merge pull request #24107 from taosdata/fix/3_liaohj
fix(stream): add check for null ptr and leader .
2023-12-18 16:24:07 +08:00
Haojun Liao 01f4912584
Merge pull request #24108 from taosdata/fix/resetHttp30
change fast failure time
2023-12-18 16:23:41 +08:00
Haojun Liao dad26d645a
Merge pull request #24110 from taosdata/fix/TD-27903
reset update info
2023-12-18 16:03:22 +08:00
yihaoDeng 1dea66d4f5 fix stream backend crash when transfer 2023-12-18 15:48:01 +08:00
wangmm0220 7f8479f953 opti:logic in parse raw line & make log more specific 2023-12-18 15:16:33 +08:00
Minglei Jin 5dd9ce8ceb fix(tsdb/cache): use int64_t instead of uint64_t for stt verRange 2023-12-18 15:02:34 +08:00
54liuyao 70a8281ef2 reset update info 2023-12-18 14:59:48 +08:00
kailixu 9fa90fc953 Merge branch '3.0' into feat/TD-27463-3.0 2023-12-18 14:20:10 +08:00
kailixu b54f816c2a feat: support uniq grant 2023-12-18 14:18:52 +08:00
yihaoDeng e0210ad513 change fast failure time 2023-12-18 14:08:37 +08:00
Benguang Zhao 25ab03e5d3 refact: improve info logging msg in mmProcessWriteMsg 2023-12-18 13:35:21 +08:00
yihaoDeng ba1b6d7c64 change fast failure time 2023-12-18 11:55:51 +08:00
Haojun Liao b4a1907fb7 fix(stream): add check for null ptr and leader . 2023-12-18 11:52:59 +08:00