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 |
|
Haojun Liao
|
2acc8423c5
|
fix(stream): send msg to mnode before closing all tasks.
|
2023-12-21 16:00:50 +08:00 |
|
Haojun Liao
|
8a8ddf5699
|
fix(stream): record the checkpoint failure when nodeEp changed.
|
2023-12-21 10:30:44 +08:00 |
|
Haojun Liao
|
32ce4b6a4c
|
fix(stream): fix race condition.
|
2023-12-20 23:12:59 +08:00 |
|
Haojun Liao
|
64eee4bbd2
|
fix(stream): add conflict check for nodeUpdate
|
2023-12-20 19:06:32 +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 |
|
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
|
94b260a1f9
|
refactor: do some internal refactor.
|
2023-12-20 10:29:04 +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 |
|
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
|
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 |
|
Haojun Liao
|
ea6e78cbaa
|
fix(stream): add async call restart, instead of sync wait.
|
2023-12-18 16:33:44 +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 |
|
yihaoDeng
|
1dea66d4f5
|
fix stream backend crash when transfer
|
2023-12-18 15:48:01 +08:00 |
|
Haojun Liao
|
b4a1907fb7
|
fix(stream): add check for null ptr and leader .
|
2023-12-18 11:52:59 +08:00 |
|
yihaoDeng
|
0840e6a0d8
|
fix stream backend crash when transfer
|
2023-12-18 11:19:15 +08:00 |
|
Haojun Liao
|
ef0cab18cb
|
Merge pull request #24098 from taosdata/fix/3_liaohj
fix(stream): send checkpoint complete msg to mnode when dropping it.
|
2023-12-17 11:03:04 +08:00 |
|
Haojun Liao
|
4f852704f5
|
fix(stream): send checkpoint complete msg to mnode when dropping it.
|
2023-12-17 02:06:01 +08:00 |
|
Haojun Liao
|
9bd80cf0f8
|
Merge pull request #24094 from taosdata/fix/TD-27905
Fix/td 27905
|
2023-12-16 18:07:17 +08:00 |