xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity
62,986 Commits 3 Branches 0 Tags 479 MiB
Commit Graph

2366 Commits

Author SHA1 Message Date
Alex Duan 22595e6432 coverage: delete checkpointTest since ci failed 2024-02-17 11:33:11 +08:00
Alex Duan 818e9254ad fix: need cleanup 2024-02-15 22:48:51 +08:00
Alex Duan 2287317da2 coverage: add checkpointTest uint test 2024-02-15 22:38:27 +08:00
54liuyao eaf10fcb43 count window fill history 2024-02-05 18:37:24 +08:00
Haojun Liao 2bba011e4e Merge remote-tracking branch 'origin/feat/TD-22023' into feat/TD-22023 2024-02-05 17:51:23 +08:00
Haojun Liao 7a18e5910c enh(stream): halt the initial stream tasks when fill-history is set for count window agg 2024-02-05 17:51:09 +08:00
54liuyao 08cb46ac3e stream count window check point 2024-02-05 15:10:03 +08:00
54liuyao b16fc7d9df Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TD-22023 2024-02-05 10:15:59 +08:00
54liuyao ea9353b9fd merge 3.0 2024-02-04 16:04:23 +08:00
Haojun Liao 3236ef7bae feat(stream): return the stream source task exec delay, and do some internal refactor. 2024-02-02 11:26:47 +08:00
Haojun Liao 87e543c824 fix(stream): pass down the transId of checkpoint, to make sure the downstream task can report the error transId successfully. 2024-02-01 17:14:36 +08:00
Haojun Liao cb2ea4a721 fix(stream): take ver snapshot for all vgroups before launching stream with fill-history option opened. 2024-02-01 11:37:57 +08:00
wangmm0220 a9fcc67321 fix:conflicts from 3.0 2024-02-01 11:13:03 +08:00
Haojun Liao 556baed25d other: merge 3.0 2024-01-30 18:35:59 +08:00
Haojun Liao 1d110953c9 refactor: do some internal refactor. 2024-01-30 15:23:54 +08:00
Haojun Liao 4970040459 refactor: do some internal refactor. 2024-01-30 15:22:49 +08:00
Haojun Liao 45891babd3
Merge pull request #24655 from taosdata/fix/3_liaohj 
refactor: do some internal refactor.
 2024-01-30 09:15:10 +08:00
Haojun Liao 3730e43f0e refactor: disable some logs. 2024-01-29 17:24:58 +08:00
54liuyao d7fb8db086 Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TD-22023 2024-01-29 16:13:39 +08:00
Haojun Liao bfbd61a02f
Merge pull request #24634 from taosdata/fix/3_liaohj 
refactor: do some internal refactor.
 2024-01-26 18:08:54 +08:00
Haojun Liao ac08f659c3 refactor: remove invalid procedure in fill-history. 2024-01-26 16:20:43 +08:00
54liuyao bc4f3d1296 Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/TD-22023 2024-01-26 15:55:06 +08:00
Haojun Liao db117a3ac7
Merge pull request #24628 from taosdata/fix/3_liaohj 
refactor: do some internal refactor.
 2024-01-26 09:09:44 +08:00
Haojun Liao 3751e11394 fix(stream): fix dead lock. 2024-01-25 17:11:16 +08:00
Haojun Liao d4bab8c09b refactor: do some internal refactor. 2024-01-25 16:53:30 +08:00
Haojun Liao 834f08a2e0
Merge pull request #24552 from taosdata/fix/3_liaohj 
fix(stream): do checkpoint after fill-history task completed.
 2024-01-25 16:53:11 +08:00
Haojun Liao 49bc3924fb fix(stream): update the check order. 2024-01-25 15:17:14 +08:00
Haojun Liao 2ecc202cb3 fix(stream): remove invalid assert. 2024-01-24 17:10:45 +08:00
Haojun Liao dc1ea9f9a1 fix(stream): clear htask info when unregistering the task. 2024-01-24 16:23:47 +08:00
Haojun Liao 1a45d40607 fix(stream): fix deadlock. 2024-01-24 14:37:46 +08:00
Haojun Liao b8856931d8 fix(stream): fix syntax error. 2024-01-24 13:11:36 +08:00
Haojun Liao 8a7e38ad15 fix(stream): fix checkpoint failure check. 2024-01-24 13:10:53 +08:00
yihaoDeng b1ac1deedb change db opt 2024-01-19 17:39:02 +08:00
Haojun Liao d973f66cea fix(stream): do checkpoint after fill-history task completed. 2024-01-19 16:18:02 +08:00
54liuyao bbabf91566 Merge branch '3.0' of https://github.com/taosdata/TDengine into 3.0 2024-01-19 14:50:16 +08:00
54liuyao 5a7d72d6ef Merge branch '3.0' of https://github.com/taosdata/TDengine into 3.0 2024-01-19 10:39:11 +08:00
wangmm0220 7246fedfef Merge branch '3.0' of https://github.com/taosdata/TDengine into feat/ly_multi_marks 2024-01-18 19:08:35 +08:00
54liuyao ff8908dede ignore invalid state 2024-01-18 18:30:21 +08:00
Haojun Liao 76e6c453e7 enh(stream): send msg to mnode when the transferring state completed. 2024-01-18 15:43:36 +08:00
Haojun Liao 719d1d1b90 refactor: do some internal refactor. 2024-01-18 14:34:18 +08:00
Haojun Liao 8620e88965 fix(stream): enable wait for timer for meta quit safely. 2024-01-18 14:17:08 +08:00
Yihao Deng 06c9b8974b rebuild stream backen from locak 2024-01-18 04:06:25 +00:00
Haojun Liao 4a2cd87de7
Merge pull request #24503 from taosdata/fix/3_liaohj 
fix(tsdb): fix race condition.
 2024-01-17 18:27:54 +08:00
Haojun Liao ba8ec6fc7b
Merge pull request #24498 from taosdata/fix/fixDebugLogError 
fix debug log err
 2024-01-17 16:55:10 +08:00
Haojun Liao 56eac88349 Merge branch '3.0' into fix/3_liaohj 2024-01-17 15:14:52 +08:00
Haojun Liao 1ea671e373 enh(stream): remove time controller. 2024-01-17 14:55:15 +08:00
Haojun Liao fc16d26da2
Merge pull request #24488 from taosdata/fix/3_liaohj 
fix(stream): fix some errors and do some internal refactor.
 2024-01-17 14:25:32 +08:00
54liuyao 3bbfb26e09 stream count window 2024-01-17 14:22:19 +08:00
Yihao Deng f27b69f0c2 fix debug log err 2024-01-17 04:46:54 +00:00
Haojun Liao 3d98fc6a67 other: merge 3.0 2024-01-16 18:29:33 +08:00
Haojun Liao 8ede6d87ce refactor: do some internal refactor. 2024-01-16 15:40:40 +08:00
jiajingbin d59ede5196 Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-28032 2024-01-16 15:05:13 +08:00
Haojun Liao 80793c94c2 fix(stream): reset the tasks status before start all tasks, and do some other internal refactor. 2024-01-16 14:32:45 +08:00
Haojun Liao dfe959eb28
Merge pull request #24468 from taosdata/fix/3_liaohj 
fix(stream): fix deadlock in pause.
 2024-01-16 12:58:27 +08:00
Haojun Liao b1c6ba467b Merge remote-tracking branch 'origin/fix/3_liaohj' into fix/3_liaohj 2024-01-16 10:28:20 +08:00
Haojun Liao 63494de7f9 refactor: do some internal refactor. 2024-01-16 10:28:07 +08:00
Yihao Deng 60c984a865 Merge branch 'fix/3_liaohj' of https://github.com/taosdata/TDengine into fix/3_liaohj 2024-01-15 11:33:16 +00:00
Yihao Deng 52b9c09d6c fix mem leak 2024-01-15 11:33:03 +00:00
Haojun Liao 5307a98f5d Merge remote-tracking branch 'origin/fix/3_liaohj' into fix/3_liaohj 2024-01-15 17:41:05 +08:00
Haojun Liao cacbb4e369 fix(stream): save the checkpoint info for sink tasks. 2024-01-15 17:40:35 +08:00
54liuyao 2e543d950a set delete for session op 2024-01-15 17:36:23 +08:00
Yihao Deng 8a2e431094 add hard link 2024-01-15 09:03:56 +00:00
wangmm0220 2ab54a1335 fix:conflicts from 3.0 2024-01-15 16:54:52 +08:00
Yihao Deng edbbd2282c Merge branch 'fix/3_liaohj' of https://github.com/taosdata/TDengine into fix/3_liaohj 2024-01-15 08:27:55 +00:00
Yihao Deng f55c93b969 add hard link 2024-01-15 08:27:35 +00:00
Haojun Liao bc657dc2d8 Merge remote-tracking branch 'origin/fix/3_liaohj' into fix/3_liaohj 2024-01-15 16:16:43 +08:00
Haojun Liao 43081b540b fix(stream): reset restart counter to be 0 if all tasks are ready. 2024-01-15 16:16:28 +08:00
Yihao Deng 14a7fe114d Merge branch 'fix/3_liaohj' of https://github.com/taosdata/TDengine into fix/3_liaohj 2024-01-15 07:47:25 +00:00
Yihao Deng 8d24a34015 add hard link 2024-01-15 07:46:30 +00:00
Haojun Liao 143e6a13af fix(stream): fix deadlock in pause. 2024-01-15 14:37:24 +08:00
Haojun Liao e012bc4bde refactor: do some internal refactor. 2024-01-15 11:28:36 +08:00
Haojun Liao d46b5e6c9a fix(stream): enable sink tasks handle the checkpoint. 2024-01-15 09:53:15 +08:00
Haojun Liao ce855bc493 refactor: do some internal refactor. 2024-01-15 09:21:31 +08:00
Haojun Liao dc1a0821a7 refactor: do some internal refactor. 2024-01-13 00:19:46 +08:00
Haojun Liao 98758862cf refactor: do some internal refactor. 2024-01-13 00:17:29 +08:00
Haojun Liao 44208925f9 refactor: do some internal refactor. 2024-01-13 00:10:47 +08:00
Haojun Liao 00e2bdec23 refactor: do some internal refactor. 2024-01-12 19:08:46 +08:00
wangmm0220 00e0da15a3 fix:[TD-28032]groupid = 0 & modify test case in sim 2024-01-12 17:37:22 +08:00
Haojun Liao 5fa8f85c42 fix(stream): remove invalid release. 2024-01-12 11:28:41 +08:00
Haojun Liao b36cc97236 fix(stream): close the inputQ of the related stream task when the fill-history task recv the trans-state msg from upstream. 2024-01-12 10:44:49 +08:00
Haojun Liao 9703018f56 fix(stream): add checkpoint status check. 2024-01-11 16:47:51 +08:00
Haojun Liao d4fd544c74 refactor: remove sleep. 2024-01-11 15:18:11 +08:00
Haojun Liao 58694c67dd refactor: do some internal refactor. 2024-01-11 11:50:52 +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 9294c8d4ee fix(stream): enable the hb to mnode for stream meta when it becomes the leader. 2024-01-11 09:20:34 +08:00
Haojun Liao dcbe963d32 fix(stream): keep the previous status in stack object. 2024-01-10 19:19:53 +08:00
wangmm0220 df69a89da2 fix:[TD-28185]add pause & resume logic for snode 2024-01-10 18:46:10 +08:00
Haojun Liao 9d0d0d9ddc Merge branch '3.0' into fix/3_liaohj 2024-01-10 09:57:46 +08:00
Haojun Liao dc0c5539a0 fix(stream): remove invalid timer controllers. 2024-01-10 08:48:49 +08:00
Haojun Liao f9d5c0d403 fix(stream): fix error in tq timer. 2024-01-09 09:13:53 +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
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
Haojun Liao bb9edde79e fix(stream): add some logs. 2024-01-08 11:33:54 +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 522e688387 fix(stream): check if in restart procedure in call back. 2024-01-05 22:16:58 +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
Haojun Liao 1912de9b49 enh(stream): scan wal by using timer to trigger it. 2024-01-05 14:49:33 +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
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
Haojun Liao 74df121cf5 fix(stream): fix the deadlock. 2024-01-03 22:29:46 +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
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
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
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
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 2387d5bade refactor: do some internal refactor. 2024-01-02 17:10:12 +08:00
Haojun Liao e7a0044502 Merge branch '3.0' into fix/3_liaohj 2024-01-02 13:02:55 +08:00
54liuyao c787535693 fix session state issue 2024-01-02 10:11:22 +08:00
Alex Duan 28238fa7dc coverage: no call function with BUILD_NO_CALL MACRO define 2023-12-31 18:29:37 +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
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 e2564a6189 fix issue 2023-12-26 18:35:49 +08:00
Haojun Liao 62cfcefbb0 refactor: remove stream-scan-history event for stream task. 2023-12-26 00:34:04 +08:00
Haojun Liao f14c3b93c1 refactor: do some internal refactor. 2023-12-25 18:22:36 +08:00
Haojun Liao 60977d56bd refactor: set attribute only on Linux 2023-12-25 12:47:16 +08:00
Haojun Liao 0877e0bfad other: merge 3.0 2023-12-25 09:13:31 +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
Haojun Liao 25f798e42f fix(stream): record the start failure tasks 2023-12-23 23:29:30 +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
Haojun Liao b175a4b7b3 refactor(stream): async stop tasks, and do some internal refactor. 2023-12-22 17:56:16 +08:00
Haojun Liao 7ce545bcd4 refactor: refactor the lock type. 2023-12-22 16:14:49 +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 90898a16e0 refactor: do some internal refactor. 2023-12-22 13:57:15 +08:00
Haojun Liao c9475060de fix(stream): fix race condition. 2023-12-22 09:34:49 +08:00
Haojun Liao 84583580e2 fix(stream): transfer the checkpoint trans id. 2023-12-21 19:12:49 +08:00