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

2246 Commits

Author SHA1 Message Date
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
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
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
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 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
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
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