Haojun Liao
|
665107ad3a
|
enh(stream): add more info in meta table.
|
2024-04-15 14:23:37 +08:00 |
|
Haojun Liao
|
15c18af221
|
fix(stream): fix init error.
|
2024-04-13 18:27:38 +08:00 |
|
Haojun Liao
|
f23a8a37bc
|
refactor: do some internal refactor.
|
2024-04-10 16:43:02 +08:00 |
wangmm0220
|
8e2a2414c0
|
fix:same subtable same partition by leads to same table name in stream
|
2024-03-28 13:48:46 +08:00 |
|
Haojun Liao
|
5157d5b97d
|
fix(stream): fix invalid read.
|
2024-03-27 15:53:24 +08:00 |
|
Haojun Liao
|
a11b2c614e
|
fix(stream): not return error when failing to load stream task meta.
|
2024-03-25 23:49:26 +08:00 |
|
Haojun Liao
|
6763ac9110
|
fix(stream):adjust current offset by using the scanning version, not the processed version in WAL.
|
2024-03-18 09:12:53 +08:00 |
|
Haojun Liao
|
8791a163f8
|
other: merge 3.0
|
2024-02-29 22:31:52 +08:00 |
|
Haojun Liao
|
db92bf84d8
|
other: merge 3.0
|
2024-02-29 22:21:50 +08:00 |
yihaoDeng
|
c54e4aeaad
|
add test case
|
2024-02-23 09:30:53 +00:00 |
|
Haojun Liao
|
b27b635c10
|
fix(stream): allow hb message rsp.
|
2024-02-21 13:55:06 +08:00 |
|
Haojun Liao
|
7e866c5527
|
refactor: do some internal refactor.
|
2024-02-19 11:32:04 +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 |
|
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
|
4970040459
|
refactor: do some internal refactor.
|
2024-01-30 15:22:49 +08:00 |
|
Haojun Liao
|
3730e43f0e
|
refactor: disable some logs.
|
2024-01-29 17:24:58 +08:00 |
|
Haojun Liao
|
d4bab8c09b
|
refactor: do some internal refactor.
|
2024-01-25 16:53:30 +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
|
8a7e38ad15
|
fix(stream): fix checkpoint failure check.
|
2024-01-24 13:10:53 +08:00 |
|
Haojun Liao
|
8620e88965
|
fix(stream): enable wait for timer for meta quit safely.
|
2024-01-18 14:17:08 +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 |
|
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
|
63494de7f9
|
refactor: do some internal refactor.
|
2024-01-16 10:28:07 +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 |
|
Haojun Liao
|
e012bc4bde
|
refactor: do some internal refactor.
|
2024-01-15 11:28:36 +08:00 |
|
Haojun Liao
|
00e2bdec23
|
refactor: do some internal refactor.
|
2024-01-12 19:08:46 +08:00 |
|
Haojun Liao
|
5fa8f85c42
|
fix(stream): remove invalid release.
|
2024-01-12 11:28:41 +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 |
|
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
|
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
|
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 |
|
Haojun Liao
|
02f6c971fd
|
fix(stream): check for not ready task when rsp returned.
|
2024-01-06 19:43:39 +08:00 |
|
Haojun Liao
|
0c4b91dc72
|
enh(stream): start task async.
|
2024-01-05 17:55:39 +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
|
4df83e92cd
|
fix(stream): fix syntax error.
|
2024-01-04 19:14:24 +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
|
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
|
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
|
e7a0044502
|
Merge branch '3.0' into fix/3_liaohj
|
2024-01-02 13:02:55 +08:00 |
Alex Duan
|
28238fa7dc
|
coverage: no call function with BUILD_NO_CALL MACRO define
|
2023-12-31 18:29:37 +08:00 |