yihaoDeng
|
6a0501967d
|
Merge branch '3.0' into fix/fixChkpRespMemleak
|
2023-11-23 14:06:04 +08:00 |
Haojun Liao
|
7b1f586d4f
|
Merge pull request #23762 from taosdata/fix/3_liaohj
fix(stream): fix error in generating token in bucket.
|
2023-11-23 09:32:14 +08:00 |
|
yihaoDeng
|
0c0d9cdd2c
|
Merge branch '3.0' into fix/fixChkpRespMemleak
|
2023-11-22 10:42:30 +08:00 |
Haojun Liao
|
b712f5e7dc
|
refactor: do some internal refactor.
|
2023-11-22 08:41:17 +08:00 |
|
Haojun Liao
|
785d91c17b
|
Merge pull request #23661 from taosdata/feat/TD-26060
fix: errors in snode in conditions like fill history/checkpoint/restart
|
2023-11-21 19:02:38 +08:00 |
|
yihaoDeng
|
a92602b667
|
fix mem leak
|
2023-11-21 15:23:28 +08:00 |
wangmm0220
|
3241f9bda5
|
fix:memory leak
|
2023-11-17 17:26:52 +08:00 |
|
Haojun Liao
|
2a1a7c82e2
|
Merge branch '3.0' into fix/3_liaohj
|
2023-11-17 10:17:14 +08:00 |
|
Haojun Liao
|
8fe79685a2
|
fix(stream): add check for assert.
|
2023-11-16 23:45:38 +08:00 |
|
wangmm0220
|
a5de1b032b
|
fix:snode upport stream task
|
2023-11-16 21:19:58 +08:00 |
|
wangmm0220
|
a16189d2a9
|
fix:confilct from 3.0
|
2023-11-15 19:14:27 +08:00 |
|
wangmm0220
|
45782f278b
|
fix:send update msg to vnodes if snode restart
|
2023-11-15 18:13:35 +08:00 |
dapan1121
|
dfb3feb5dc
|
Merge remote-tracking branch 'origin/main' into merge/m23
|
2023-11-15 11:39:18 +08:00 |
|
Haojun Liao
|
f99e22b91f
|
fix(stream): fix deadlock.
|
2023-11-13 23:56:42 +08:00 |
|
Haojun Liao
|
aad8a2eb87
|
fix(stream): fix deadlock.
|
2023-11-13 18:20:30 +08:00 |
|
Haojun Liao
|
8925c721e5
|
fix(stream): adjust critical section.
|
2023-11-11 15:40:16 +08:00 |
|
Haojun Liao
|
5937bdddf5
|
refactor:disable test.
|
2023-11-11 15:40:12 +08:00 |
|
Haojun Liao
|
cb0d244d5a
|
fix(stream): release lock.
|
2023-11-11 15:40:11 +08:00 |
|
Haojun Liao
|
af08a189c1
|
fix(stream): disable concurrently restart stream tasks.
|
2023-11-11 15:40:10 +08:00 |
|
Haojun Liao
|
4d9b422874
|
fix(stream): check for the repeatedly sent checkpoint-source msg.
|
2023-11-11 15:40:10 +08:00 |
|
Haojun Liao
|
45ab92a02d
|
fix(stream): remove invalid free.
|
2023-11-11 15:39:55 +08:00 |
|
Haojun Liao
|
77d6fd5394
|
refactor: do some internal refactor.
|
2023-11-11 15:39:09 +08:00 |
|
Haojun Liao
|
608c72e901
|
refactor(stream): create sim env for stream processing.
|
2023-11-11 15:39:08 +08:00 |
|
Haojun Liao
|
233777b6ac
|
fix(stream): adjust critical section.
|
2023-11-10 10:26:45 +08:00 |
|
Haojun Liao
|
d8ab8d2d03
|
refactor:disable test.
|
2023-11-10 09:46:20 +08:00 |
|
Haojun Liao
|
ed49294e9b
|
fix(stream): release lock.
|
2023-11-10 09:35:41 +08:00 |
|
Haojun Liao
|
9978667c48
|
fix(stream): disable concurrently restart stream tasks.
|
2023-11-10 09:24:08 +08:00 |
|
Haojun Liao
|
730434ed82
|
fix(stream): check for the repeatedly sent checkpoint-source msg.
|
2023-11-09 23:26:09 +08:00 |
|
Haojun Liao
|
62f34c757e
|
fix(stream): remove invalid free.
|
2023-11-09 10:10:37 +08:00 |
|
Haojun Liao
|
658fafd03c
|
refactor: do some internal refactor.
|
2023-11-08 14:02:08 +08:00 |
|
Haojun Liao
|
809dd064a7
|
refactor(stream): create sim env for stream processing.
|
2023-11-08 11:04:16 +08:00 |
|
Haojun Liao
|
2674698b36
|
fix(stream): restart tasks in stream threads, instead of write thread.
|
2023-11-07 18:51:46 +08:00 |
|
Haojun Liao
|
1301b92844
|
fix(stream): fix errors in scan-history, introduced by refactor
|
2023-11-07 16:41:15 +08:00 |
|
Haojun Liao
|
8c2f6bab0e
|
fix(stream): exec scan-history in timer.
|
2023-11-07 16:40:03 +08:00 |
|
Haojun Liao
|
207b53f3f6
|
fix(stream): fix errors in scan-history, introduced by refactor
|
2023-11-07 16:19:09 +08:00 |
|
Haojun Liao
|
4d8548e938
|
refactor: do some internal refactor.
|
2023-11-06 23:42:16 +08:00 |
|
Haojun Liao
|
d9474016fc
|
fix(stream): exec scan-history in timer.
|
2023-11-06 18:55:53 +08:00 |
|
Haojun Liao
|
d41fd27189
|
fix(stream): restart tasks in stream threads, instead of write thread.
|
2023-11-06 11:57:21 +08:00 |
|
Haojun Liao
|
0e44950a37
|
enh(stream): execute scan history by using time slice 1s.
|
2023-11-06 09:21:33 +08:00 |
|
Haojun Liao
|
680eb5674e
|
refactor: do some internal refactor.
|
2023-11-06 09:15:49 +08:00 |
|
Haojun Liao
|
d440da0d8c
|
enh(stream): execute scan history by using time slice 1s.
|
2023-11-05 01:26:53 +08:00 |
|
Haojun Liao
|
e13f003b90
|
refactor: do some internal refactor.
|
2023-11-05 01:23:23 +08:00 |
|
Haojun Liao
|
b3d57e4a2d
|
fix(stream): not transfer state if state is not appropriate.
|
2023-11-02 19:31:35 +08:00 |
|
Haojun Liao
|
7a32b3a209
|
fix(stream): not transfer state if state is not appropriate.
|
2023-11-02 19:12:36 +08:00 |
|
Haojun Liao
|
c4079332ff
|
fix(stream):update the log level.
|
2023-11-02 18:18:04 +08:00 |
|
Haojun Liao
|
0a227e807f
|
refactor: set different tq level.
|
2023-11-02 18:18:04 +08:00 |
|
Haojun Liao
|
48aff868b6
|
fix(stream):update the log level.
|
2023-11-02 18:16:47 +08:00 |
|
Haojun Liao
|
3aed8c29ae
|
refactor: set different tq level.
|
2023-11-02 17:12:20 +08:00 |
|
Haojun Liao
|
95efa07e92
|
fix(stream): add full unsupported event filtering.
|
2023-11-02 11:02:39 +08:00 |
|
Haojun Liao
|
351a31302f
|
fix(stream): add full unsupported event filtering.
|
2023-11-02 09:43:48 +08:00 |