Commit Graph

12058 Commits

Author SHA1 Message Date
wade zhang bef2991211
Merge pull request #23691 from taosdata/fix/TD-27303-main
TD-27303
2023-11-15 11:23:00 +08:00
dmchen 056993b519 TD-27303 2023-11-14 11:10:22 +00:00
Haojun Liao b390ee859c fix(stream): send msg by using epset extract from mnode, instead of cached epset in streamObj. 2023-11-14 17:04:54 +08:00
Haojun Liao cfa7c19dd5
Merge pull request #23667 from taosdata/fix/liaohj
fix(stream): fix deadlock.
2023-11-13 22:15:06 +08:00
Haojun Liao aad8a2eb87 fix(stream): fix deadlock. 2023-11-13 18:20:30 +08:00
wade zhang 05d7274d98
Merge pull request #23639 from taosdata/fix/TS-4249-main
TS-4249
2023-11-13 10:03:18 +08:00
Haojun Liao 438c303b0d other: merge main. 2023-11-10 17:05:36 +08:00
dmchen ae1347fe5a login 2023-11-10 08:53:29 +00:00
dmchen fc8b16a5f3 password 2023-11-10 08:43:24 +00:00
Haojun Liao 08a9244230 fix(stream): extact stream nodes list if not initialized. 2023-11-10 16:24:20 +08:00
dmchen 22d6204fa9 TS-4249 2023-11-10 08:23:09 +00:00
Haojun Liao d0307e5876 refactor: 2023-11-10 15:30:21 +08:00
Haojun Liao 0b36081158 refactor:add some logs. 2023-11-10 14:36:18 +08:00
Haojun Liao 5824caa8f5
Merge pull request #23631 from taosdata/fix/liaohj
multiple fix
2023-11-10 13:09:40 +08:00
wade zhang 6bea2fe36a
Merge pull request #23625 from taosdata/fix/TD-27243-main
fix/TD-27243
2023-11-10 11:06:00 +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
dmchen 65bebb0912 fix/TD-27243 2023-11-09 09:51:35 +00:00
yihaoDeng ef726fee53 change chkpid gen way 2023-11-09 13:58:36 +08:00
Haojun Liao 62f34c757e fix(stream): remove invalid free. 2023-11-09 10:10:37 +08:00
yihaoDeng 17ea6f39c1 change chkp gen way 2023-11-09 09:55:09 +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 666b8c531b
Merge pull request #23548 from taosdata/fix/liaohj
refactor: do some internal refactor.
2023-11-08 08:08:36 +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 6b1889284b fix(stream): record the start failure tasks. 2023-11-06 15:45:44 +08:00
Haojun Liao 69863febe6 fix(stream):reset the starting flag for the followers. 2023-11-06 13:17:13 +08:00
Haojun Liao bfd14076d7 fix(stream): fix dead-lock. 2023-11-06 12:05:47 +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 3415ba5195
Merge pull request #23528 from taosdata/fix/liaohj
enh(tsdb): on-demand open stt file reader.
2023-11-03 17:29:55 +08:00
Haojun Liao d3ddaaa9f3 other(tsdb): adjust some log info. 2023-11-03 15:08:25 +08:00
Haojun Liao c980e2030c fix(tsdb): fix error during add on-demand opening stt file reader. 2023-11-03 11:04:32 +08:00
Haojun Liao 0acf4f1795 enh(tsdb): on-demand open stt file reader. 2023-11-03 10:35:05 +08:00
Haojun Liao 70388bafd2
Merge pull request #23523 from taosdata/fix/liaohj
fix(stream): fix deadlock in transfer state.
2023-11-03 09:07:23 +08:00
wade zhang dc581a83a1
Merge pull request #23495 from taosdata/fix/audit-db-resource-main
db and resource
2023-11-02 19:33:25 +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 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 f5fa3edeba
Merge pull request #23503 from taosdata/fix/liaohj
fix(stream): fix dead lock.
2023-11-02 13:52:50 +08:00
Haojun Liao 351a31302f fix(stream): add full unsupported event filtering. 2023-11-02 09:43:48 +08:00
Haojun Liao 246ed4e022 refactor: do some internal refactor. 2023-11-01 17:19:21 +08:00
Haojun Liao 12bc4f32cf refactor: add some logs. 2023-11-01 16:12:15 +08:00
Haojun Liao 034546a490
Merge pull request #23445 from taosdata/fix/TD-26685-new
fix:print log if assert & check epoch when update epoch
2023-11-01 15:32:40 +08:00