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 |
|
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
|
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 |
|
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 |
|
Haojun Liao
|
1ca06e960f
|
fix(stream): remove stream in buf.
|
2023-09-18 20:25:24 +08:00 |
|
Haojun Liao
|
c33ef4ce88
|
fix(stream): add null check
|
2023-09-18 15:14:51 +08:00 |
Haojun Liao
|
8aa34802f5
|
Merge pull request #22938 from taosdata/fix/TD-26323
fix:[TD-26323]add macro to control tmq assert & make subscribe transa…
|
2023-09-18 09:48:39 +08:00 |
|
Haojun Liao
|
8aa9960760
|
Merge pull request #22944 from taosdata/fix/liaohj
refactor: do some internal refactor, and fix some bugs.
|
2023-09-17 21:25:33 +08:00 |
|
Haojun Liao
|
3dfdda3283
|
fix(stream): fix error in decode stream task.
|
2023-09-17 18:07:26 +08:00 |
|
Haojun Liao
|
01144c58a7
|
fix(stream): fix stream task id error.
|
2023-09-17 01:19:59 +08:00 |
|
Haojun Liao
|
4846194bbb
|
refactor: do some internal refactor, remove the related fill-history task by sending mesg to replay it in follower node.
|
2023-09-16 21:37:30 +08:00 |
|
Haojun Liao
|
caa7542cea
|
Merge pull request #22913 from taosdata/fix/liaohj
fix(stream): fix error in drop task.
|
2023-09-16 21:36:38 +08:00 |
wangmm0220
|
8ebb6e202e
|
fix:[TD-26323]add macro to control tmq assert & make subscribe transaction no conflicts
|
2023-09-15 19:26:55 +08:00 |
|
Haojun Liao
|
91e3d70796
|
fix(stream): remove fill-history sink task.
|
2023-09-15 17:46:17 +08:00 |
Alex Duan
|
47f2c38a56
|
Merge pull request #22910 from taosdata/fix/TS-3987
fix: delete data error
|
2023-09-15 16:19:29 +08:00 |
wade zhang
|
b123dd7df3
|
Merge pull request #22904 from taosdata/FIX/TD-26292-main
enh: ignore compact req during restoring
|
2023-09-15 11:05:18 +08:00 |
|
Haojun Liao
|
2bfd6e3355
|
refactor: do some internal refactor.
|
2023-09-15 09:25:22 +08:00 |
|
Haojun Liao
|
117de7ab7d
|
fix(stream): fix error in drop task.
|
2023-09-15 00:51:13 +08:00 |
|
Haojun Liao
|
500fcad36c
|
Merge pull request #22892 from taosdata/fix/liaohj
refactor: do some internal refactor.
|
2023-09-15 00:46:46 +08:00 |
|
Haojun Liao
|
73c2782d78
|
fix(stream): update some logs.
|
2023-09-14 23:17:23 +08:00 |
|
Haojun Liao
|
5f55f489d8
|
fix(stream): fix memory leak.
|
2023-09-14 22:59:11 +08:00 |
|
Haojun Liao
|
303e8caf0c
|
fix(stream): set the correct guard flag.
|
2023-09-14 22:44:16 +08:00 |
|
Haojun Liao
|
27f626769e
|
fix(stream): fix memory leak.
|
2023-09-14 19:33:05 +08:00 |
|
Haojun Liao
|
f2c3e0a6e8
|
fix(stream): disable follower send hb to mnode. and do some internal refactor.
|
2023-09-14 17:22:31 +08:00 |
Hongze Cheng
|
925cc8f55f
|
fix: delete data error
|
2023-09-14 17:20:10 +08:00 |
Benguang Zhao
|
2886913fd8
|
enh: ignore compact req during restoring
|
2023-09-14 16:09:00 +08:00 |
|
Haojun Liao
|
fce5be0eb4
|
fix(stream): fix dead lock.
|
2023-09-14 14:09:05 +08:00 |
|
Haojun Liao
|
fd6344b319
|
fix(tsdb): check return code.
|
2023-09-14 09:25:35 +08:00 |
|
Haojun Liao
|
9b70c0c457
|
fix:fix coverity issue and remove unnecessary files.
|
2023-09-14 09:06:10 +08:00 |
|
Haojun Liao
|
7305c8dbe1
|
refactor: do some internal refactor about the sched status set
|
2023-09-13 14:00:34 +08:00 |
|
Haojun Liao
|
99477babca
|
Merge pull request #22872 from taosdata/fix/coverityScanDyh
fix coverity scan problem
|
2023-09-13 09:18:27 +08:00 |
|
Haojun Liao
|
09a15bf340
|
refactor: do some internal refactor.
|
2023-09-12 22:07:52 +08:00 |
|
Haojun Liao
|
4325a0a433
|
Merge pull request #22866 from taosdata/fix/3_liaohj
refactor: do some internal refactor.
|
2023-09-12 21:56:44 +08:00 |
yihaoDeng
|
8fc33dd74d
|
fix coverity scan problem
|
2023-09-12 18:52:16 +08:00 |
|
Haojun Liao
|
e457d94ac6
|
refactor: do some internal refactor.
|
2023-09-12 18:09:02 +08:00 |
|
Haojun Liao
|
4d33387e80
|
Merge pull request #22814 from taosdata/fix/fixTransferCrash2
fix merge error
|
2023-09-12 16:10:07 +08:00 |
|
Haojun Liao
|
52931b530d
|
Merge pull request #22855 from taosdata/fix/3_liaohj
fix(stream):check error when vnode is closing.
|
2023-09-12 15:58:02 +08:00 |
dapan1121
|
ef7eb478e4
|
Merge pull request #22834 from taosdata/fix/TS-3945
fix: remove incorrect assert
|
2023-09-12 15:55:51 +08:00 |
|
yihaoDeng
|
63c53b6a3a
|
fix transfer crash
|
2023-09-12 15:03:13 +08:00 |