Haojun Liao
|
dbc53069db
|
Merge branch 'main' into fix/liaohj
|
2023-09-25 10:41:18 +08:00 |
Haojun Liao
|
1af95969b2
|
fix(stream): adjust nodeUpdate check interval.
|
2023-09-25 10:40:30 +08:00 |
|
Haojun Liao
|
eb4078b7f3
|
fix(stream): record the tasks started info, and do some internal refactor.
|
2023-09-25 09:59:05 +08:00 |
|
Haojun Liao
|
c987f61300
|
fix(stream): fix race condition.
|
2023-09-25 01:37:27 +08:00 |
|
Haojun Liao
|
4ea737571d
|
refactor: do some internal refactor.
|
2023-09-24 01:26:51 +08:00 |
|
Haojun Liao
|
b58ec1ee57
|
fix(stream): update logs.
|
2023-09-23 15:22:48 +08:00 |
|
Haojun Liao
|
acd3321494
|
fix(stream): rsp when checkpoint source failed.
|
2023-09-23 14:13:33 +08:00 |
|
Haojun Liao
|
7d5f76c6f1
|
fix(stream): disable auto rsp for checkpoint source.
|
2023-09-23 11:31:14 +08:00 |
|
Haojun Liao
|
5155519559
|
fix(stream): fix invalid assert.
|
2023-09-22 23:06:48 +08:00 |
|
Haojun Liao
|
cf6c255f22
|
refactor: do some internal refactor.
|
2023-09-22 22:50:21 +08:00 |
|
Haojun Liao
|
fcbd747afc
|
fix(stream): fix race condition.
|
2023-09-22 19:35:12 +08:00 |
|
Haojun Liao
|
5b12e276cf
|
fix(stream): add msg identifier check.
|
2023-09-22 18:13:18 +08:00 |
|
Haojun Liao
|
898aea5cfb
|
refactor(stream): refactor send msg.
|
2023-09-22 14:52:18 +08:00 |
|
Haojun Liao
|
7380151322
|
fix(stream): remove invalid node.
|
2023-09-22 11:45:46 +08:00 |
|
Haojun Liao
|
87ea745861
|
fix(stream): add some logs, and remove invalid assert.
|
2023-09-22 10:53:03 +08:00 |
|
Haojun Liao
|
198e6bb023
|
enh(stream): add stage info for streamt tasks.
|
2023-09-22 10:36:15 +08:00 |
|
Haojun Liao
|
f7bcff862d
|
fix(stream): add check info detailed information.
|
2023-09-22 10:23:56 +08:00 |
|
Haojun Liao
|
b1ba716299
|
refactor: do some internal refactor.
|
2023-09-22 09:24:36 +08:00 |
|
Haojun Liao
|
b075b4438b
|
fix(stream): handle dispatch checkpoint-trigger failure.
|
2023-09-21 23:15:18 +08:00 |
|
Haojun Liao
|
2efd155adf
|
fix(stream): wait for the task checkpoint before stop.
|
2023-09-21 15:53:21 +08:00 |
|
Haojun Liao
|
0f97a21163
|
fix(tsdb): set the correct scaninfo to load the tomb data.
|
2023-09-21 15:21:01 +08:00 |
|
Haojun Liao
|
e4073bd9a8
|
fix(stream): update logs.
|
2023-09-21 14:03:14 +08:00 |
|
Haojun Liao
|
09accc71d2
|
log(stream): update log.
|
2023-09-21 14:01:41 +08:00 |
|
Haojun Liao
|
17586af0ce
|
refactor: do refactor the sink task.
|
2023-09-21 13:32:57 +08:00 |
|
Haojun Liao
|
92f18989df
|
fix(stream): remove invalid cached task info in buffer.
|
2023-09-20 19:19:04 +08:00 |
|
Haojun Liao
|
6633fb971b
|
fix(stream): update logs.
|
2023-09-20 18:18:31 +08:00 |
|
Haojun Liao
|
2418f509ea
|
fix(stream): avoid invalid read.
|
2023-09-20 15:47:09 +08:00 |
|
Haojun Liao
|
1d1d9a1b0b
|
fix(stream): unlock when returning.
|
2023-09-20 15:45:15 +08:00 |
|
Haojun Liao
|
c8ab761d2a
|
fix(stream): return if failed.
|
2023-09-20 15:38:49 +08:00 |
|
Haojun Liao
|
2a781c509f
|
fix(stream): add task status check.
|
2023-09-20 15:32:15 +08:00 |
|
Haojun Liao
|
af487c9048
|
fix(stream): fix obj.
|
2023-09-20 14:50:43 +08:00 |
|
Haojun Liao
|
361cde6497
|
fix(stream): fix deadlock caused by streamTaskHalt function.
|
2023-09-20 14:49:09 +08:00 |
|
Haojun Liao
|
55d4a9686c
|
log(tsdb): remove some logs.
|
2023-09-20 13:18:42 +08:00 |
|
Haojun Liao
|
5e3a268b6d
|
enh(stream): add info in log.
|
2023-09-20 13:15:50 +08:00 |
dm chen
|
4497a01168
|
Merge branch 'main' into feat/TD-26127-audit-sql
|
2023-09-20 11:13:34 +08:00 |
|
Haojun Liao
|
392aaeb592
|
log(stream): remove logs.
|
2023-09-20 10:49:18 +08:00 |
|
Haojun Liao
|
b4419bda65
|
enh(stream): add node stage check.
|
2023-09-20 10:35:01 +08:00 |
|
Haojun Liao
|
779c0c5f19
|
Merge pull request #22970 from taosdata/fix/liaohj
fix(stream): keep the status entry in hash table, instead entry index.
|
2023-09-20 10:33:05 +08:00 |
|
dmchen
|
1a7bffb079
|
ci break
|
2023-09-19 18:01:38 +08:00 |
|
Haojun Liao
|
b99232fd7a
|
fix(stream): limit the max scan times.
|
2023-09-19 17:45:28 +08:00 |
|
Haojun Liao
|
271e492188
|
refactor: update the log level.
|
2023-09-19 17:40:26 +08:00 |
|
dmchen
|
dbde1a4491
|
ci break
|
2023-09-19 14:40:48 +08:00 |
|
dm chen
|
ee913cbfbc
|
Merge branch 'main' into feat/TD-26127-audit-sql
|
2023-09-19 14:39:20 +08:00 |
|
dmchen
|
e36ff1282c
|
revert dependency
|
2023-09-19 13:42:02 +08:00 |
wade zhang
|
7311e60f7f
|
Merge pull request #22963 from taosdata/fix/TS-4015
fix: set snapshot writer compression
|
2023-09-19 13:26:32 +08:00 |
|
Haojun Liao
|
1cfd34a6a9
|
Merge pull request #22955 from taosdata/fix/avoidConflictIdxNameMain
avoid first tag index conflict
|
2023-09-19 11:37:26 +08:00 |
slzhou
|
c882f4ba08
|
fix: fix address sanitizer error
|
2023-09-19 11:31:20 +08:00 |
|
Haojun Liao
|
5a6e50d523
|
fix(stream): keep the status entry in hash table, instead entry index.
|
2023-09-19 10:33:58 +08:00 |
|
Haojun Liao
|
e76bab7122
|
fix(stream): not handle the check msg for follower tasks.
|
2023-09-19 09:43:14 +08:00 |
|
slzhou
|
900aacd428
|
fix: fix sanitizer error
|
2023-09-19 09:40:00 +08:00 |