Haojun Liao
|
3d98fc6a67
|
other: merge 3.0
|
2024-01-16 18:29:33 +08:00 |
|
Haojun Liao
|
0280f129bd
|
fix(stream):add some logs.
|
2024-01-16 18:21:29 +08:00 |
|
Haojun Liao
|
882b916940
|
fix(stream): adjust stream trans conflict check.
|
2024-01-16 16:11:04 +08:00 |
|
Haojun Liao
|
8ede6d87ce
|
refactor: do some internal refactor.
|
2024-01-16 15:40:40 +08:00 |
Yihao Deng
|
7a09ba2630
|
fix pause/resume error
|
2024-01-15 11:56:38 +00:00 |
Haojun Liao
|
1296700092
|
Merge pull request #24433 from taosdata/fix/TD-28188
fix:[TD-28188]the epset of snode is error because epset is not initil…
|
2024-01-15 17:05:11 +08: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
|
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 |
|
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 |
|
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 |
|
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
|
e7a0044502
|
Merge branch '3.0' into fix/3_liaohj
|
2024-01-02 13:02:55 +08:00 |
|
Haojun Liao
|
7abeb5a27a
|
fix(stream): update the stream error code.
|
2023-12-29 17:44:10 +08:00 |
|
Haojun Liao
|
62cfcefbb0
|
refactor: remove stream-scan-history event for stream task.
|
2023-12-26 00:34:04 +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
|
0fab9a1827
|
other: fix syntax error.
|
2023-12-22 00:29:49 +08:00 |
|
Haojun Liao
|
84583580e2
|
fix(stream): transfer the checkpoint trans id.
|
2023-12-21 19:12:49 +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 |
|
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 |
|
Haojun Liao
|
bba5a4f08b
|
other: merge main into 3.0
|
2023-12-18 18:26:42 +08:00 |
|
Haojun Liao
|
edc3841a2c
|
fix(stream): avoid invalid read.
|
2023-12-18 09:26:56 +08:00 |
|
Haojun Liao
|
f9a5485d52
|
fix(stream): refactor the stream trans conflict detection strategy.
|
2023-12-16 01:46:29 +08:00 |
|
Haojun Liao
|
aedc5e6b05
|
fix(stream): set the correct dst stable name.
|
2023-12-15 17:16:25 +08:00 |
|
Haojun Liao
|
0449b5f1bd
|
other: add some logs.
|
2023-12-14 15:43:59 +08:00 |
|
Haojun Liao
|
105542bb21
|
fix(stream):handle the case of delete orphaned tasks.
|
2023-12-13 17:44:00 +08:00 |
|
Haojun Liao
|
4d9211dcf1
|
Merge pull request #23899 from taosdata/fix/liaohj
other: merge the patch of stream from 3.0 branch.
|
2023-12-01 15:49:54 +08:00 |
|
Haojun Liao
|
d7a19a9179
|
fix(stream): fix invalid decode hbmsg and memory leaks caused by invalid hb msg.
|
2023-12-01 14:45:18 +08:00 |
|
Haojun Liao
|
7e63943c4e
|
Merge pull request #23860 from taosdata/fix/TD-27455
fix:tmqVnodeSplit-column.py failed in arm64 because of rebalance after unsubscribe while split vnode
|
2023-12-01 14:18:58 +08:00 |
|
Haojun Liao
|
33ad05e2c8
|
fix(stream): fix syntax error.
|
2023-12-01 13:08:25 +08:00 |
|
Haojun Liao
|
12f32f0ae7
|
fix(stream): fix syntax error.
|
2023-12-01 11:57:16 +08:00 |
|
Haojun Liao
|
dba58f5e38
|
fix(stream): fix syntax error.
|
2023-12-01 11:54:13 +08:00 |
|
Haojun Liao
|
18273b8d1b
|
fix(stream): ignore the in_progress code.
|
2023-12-01 10:20:45 +08:00 |
|
Haojun Liao
|
2972f5f420
|
fix(stream):return the error code if create stream failed.
|
2023-12-01 10:20:45 +08:00 |
|
Haojun Liao
|
86618ffd97
|
refactor: do some internal refactor.
|
2023-12-01 10:20:38 +08:00 |
|
Haojun Liao
|
31ae46925d
|
fix(stream): fix invalid free.
|
2023-12-01 10:20:32 +08:00 |
|
Haojun Liao
|
c937f42d88
|
fix(stream): fix deadlock.
|
2023-12-01 10:19:54 +08:00 |
|
Haojun Liao
|
8515a2f9b6
|
fix(stream): fix status check for stream-scan-history status when drop stream task msg is missing.
|
2023-12-01 10:19:18 +08:00 |
|
Haojun Liao
|
9d735e7f8b
|
fix(stream): reduce the sink throughput. and fix the bug in status check.
|
2023-12-01 10:18:25 +08:00 |
|
Haojun Liao
|
523573844a
|
fix(stream): fix syntax error.
|
2023-12-01 10:18:24 +08:00 |
|
Haojun Liao
|
eb2f5ad074
|
fix(stream): fix error.
|
2023-12-01 10:18:22 +08:00 |
|
Haojun Liao
|
2b03d64850
|
fix(stream): drop the related fill-history task & set the task to be ready, if the drop fill-history task msg is missing due to the vnode restarting.
|
2023-12-01 10:18:15 +08:00 |
|
Haojun Liao
|
60fa7cccbf
|
fix(stream): fix memory leak.
|
2023-12-01 10:17:14 +08:00 |
|
wangmm0220
|
4fc19a6343
|
fix:snode can only be created 1
|
2023-11-30 15:49:31 +08:00 |
|
Haojun Liao
|
999afd97e5
|
other: merge 3.0
|
2023-11-30 14:36:18 +08:00 |
|
Haojun Liao
|
de82aba2e5
|
fix(stream): ignore the in_progress code.
|
2023-11-30 14:32:14 +08:00 |
|
Haojun Liao
|
71860bfb46
|
fix(stream):return the error code if create stream failed.
|
2023-11-30 13:57:00 +08:00 |