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 |
|
Haojun Liao
|
bc7434e2b5
|
fix(stream): set error code for return.
|
2024-01-12 14:49:16 +08:00 |
|
Haojun Liao
|
5fa8f85c42
|
fix(stream): remove invalid release.
|
2024-01-12 11:28:41 +08:00 |
|
Haojun Liao
|
cf941f7488
|
fix(stream): check status when resume to run.
|
2024-01-12 11:12:23 +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
|
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
|
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 |
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 |
|
wangmm0220
|
df69a89da2
|
fix:[TD-28185]add pause & resume logic for snode
|
2024-01-10 18:46:10 +08:00 |
|
wangmm0220
|
27b63b721f
|
fix:decode mqDataMsg error for the message with old version
|
2024-01-10 17:36:51 +08: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 |
|
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 |
|
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 |
|
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 |
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 |
|
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 |