yihaoDeng
|
7ac4ef5beb
|
add sess iter
|
2023-10-10 10:41:46 +08:00 |
dapan1121
|
9c5dbb3978
|
Merge pull request #23189 from taosdata/fix/TD-26426-3.0
fix: alter active code for different server
|
2023-10-10 10:37:39 +08:00 |
liuyao
|
26c87e5f41
|
fix mem leak
|
2023-10-10 10:26:26 +08:00 |
Hongze Cheng
|
1b559a0254
|
Merge pull request #23180 from taosdata/fix/TS-4121-main
fix(tsdb/cache reader): reset current fileset in cache reader
|
2023-10-09 20:46:33 -05:00 |
wangmm0220
|
660e77606e
|
docs:modify format
|
2023-10-10 09:15:10 +08:00 |
|
Hongze Cheng
|
4224f90661
|
Merge pull request #23184 from taosdata/enh/TS-4107
enh: clear files fset by fset
|
2023-10-09 20:05:12 -05:00 |
|
wangmm0220
|
d42e819d2d
|
feat:[TD-26056] add replay logic
|
2023-10-10 09:02:37 +08:00 |
slzhou
|
da9d39bfe6
|
fix: cancel future pseudo column translation function processing when rewritten to column
|
2023-10-10 08:31:23 +08:00 |
|
slzhou
|
b8fe279a85
|
fix: renanme function
|
2023-10-10 07:44:29 +08:00 |
Jeff Tao
|
fe41fd23b2
|
Update 70-seeq.md
|
2023-10-09 15:33:40 -07:00 |
Haojun Liao
|
890f2d5c93
|
test: update the test cases.
|
2023-10-09 22:52:00 +08:00 |
|
wangmm0220
|
b12c734f09
|
feat:[TD-26056] add replay logic
|
2023-10-09 21:14:32 +08:00 |
|
yihaoDeng
|
0fc6ffe6b6
|
change test case
|
2023-10-09 20:51:26 +08:00 |
|
yihaoDeng
|
8fa631cb62
|
change test case
|
2023-10-09 20:47:06 +08:00 |
|
Haojun Liao
|
776897cdc0
|
test: update the test cases.
|
2023-10-09 20:10:28 +08:00 |
|
Haojun Liao
|
a25d94ab6f
|
fix(stream): retry when error occurs during timer.
|
2023-10-09 20:10:28 +08:00 |
|
Haojun Liao
|
7d39164133
|
fix(stream): disable retrieving results during checkpoint procedure
|
2023-10-09 20:10:27 +08:00 |
|
Haojun Liao
|
af4618f958
|
fix(stream): remove invalid clear of rspmsg list.
|
2023-10-09 20:10:27 +08:00 |
|
Haojun Liao
|
847baa8b71
|
fix(stream): fix the pause failure bug.
|
2023-10-09 20:10:27 +08:00 |
|
Haojun Liao
|
21fb502690
|
enh(stream): add trans to reset task status to avoid being frozen in checkpoint status due to doing checkpoint failure of partial tasks.
|
2023-10-09 20:10:26 +08:00 |
|
Haojun Liao
|
c5ee299d01
|
fix(stream): fix error in fill-history process.
|
2023-10-09 20:10:26 +08:00 |
|
Haojun Liao
|
64bde93f85
|
fix(stream): not idle for sink task when no tokens are available.
|
2023-10-09 20:10:25 +08:00 |
|
Haojun Liao
|
9a7167aaba
|
fix(stream): sleep for 10ms
|
2023-10-09 20:10:24 +08:00 |
|
Haojun Liao
|
9af8ce21ed
|
fix(stream): wait for a while when no available token.
|
2023-10-09 20:10:23 +08:00 |
|
Haojun Liao
|
4780474877
|
fix(stream): continue
|
2023-10-09 20:10:23 +08:00 |
|
Haojun Liao
|
da833ccb30
|
refactor: inc the dump batch.
|
2023-10-09 20:10:23 +08:00 |
|
Haojun Liao
|
2936ac9b89
|
fix(stream): add missing refactor.
|
2023-10-09 20:10:22 +08:00 |
|
Haojun Liao
|
af2c0c95e9
|
refactor: do some internal refactor.
|
2023-10-09 20:10:22 +08:00 |
|
Haojun Liao
|
940d6a3cb4
|
fix(stream): check items in queue and qall, stead of only the queue items.
|
2023-10-09 20:10:21 +08:00 |
|
Haojun Liao
|
e95aea84ae
|
fix(stream): fix syntax error.
|
2023-10-09 20:10:21 +08:00 |
|
Haojun Liao
|
59e284c332
|
fix(stream): quit from loop when input queue is full.
|
2023-10-09 20:10:21 +08:00 |
|
Haojun Liao
|
9d5a3b8d78
|
other: merge stream fix.
|
2023-10-09 20:10:13 +08:00 |
|
Haojun Liao
|
11d8c8da39
|
fix(stream): update the sink data.
|
2023-10-09 20:09:23 +08:00 |
|
Haojun Liao
|
c5997bee5b
|
fix(stream): update the current processing version.
|
2023-10-09 20:09:23 +08:00 |
|
Haojun Liao
|
f0c5b5a970
|
refactor(stream): revised the display info.
|
2023-10-09 20:09:22 +08:00 |
|
Haojun Liao
|
28008f8263
|
enh(stream): add more info for sink task.
|
2023-10-09 20:09:22 +08:00 |
|
Haojun Liao
|
b3b9e89d30
|
fix(stream): fix the invalid check.
|
2023-10-09 20:09:22 +08:00 |
|
Haojun Liao
|
65daf38715
|
refactor(stream): idle for 100ms when starting next round scan wal.
|
2023-10-09 20:09:22 +08:00 |
|
Haojun Liao
|
cf14772dd9
|
enh(stream): optimize the scan wal perf
|
2023-10-09 20:09:21 +08:00 |
|
Haojun Liao
|
d2160efa05
|
refactor: wait for 100ms before scan wal again.
|
2023-10-09 20:09:21 +08:00 |
|
Haojun Liao
|
932d93ab35
|
refactor: wait for more time for future data
|
2023-10-09 20:09:21 +08:00 |
|
Haojun Liao
|
7682c033ad
|
fix(stream): add null check.
|
2023-10-09 20:09:21 +08:00 |
|
Haojun Liao
|
0ab5d4b342
|
refactor: do some internal refactor.
|
2023-10-09 20:09:20 +08:00 |
|
Haojun Liao
|
c295ec322a
|
refactor: do some internal refactor.
|
2023-10-09 20:09:20 +08:00 |
|
Haojun Liao
|
d5abb21335
|
fix(stream): fix invalid check.
|
2023-10-09 20:09:20 +08:00 |
|
Haojun Liao
|
583ac1fc45
|
refactor: do some internal refactor.
|
2023-10-09 20:09:20 +08:00 |
|
Haojun Liao
|
19042cdea6
|
fix(stream): fix invalid param.
|
2023-10-09 20:09:19 +08:00 |
|
Haojun Liao
|
f9113ab7b0
|
fix(stream): fix invalid param.
|
2023-10-09 20:09:11 +08:00 |
|
Haojun Liao
|
b0a4ed3217
|
fix(stream): drop related fill-history task when dropping stream tasks.
|
2023-10-09 20:09:10 +08:00 |
|
Haojun Liao
|
83f84d92bc
|
refactor: do some internal refactor (discard the checkpoint source msg during restoring).
|
2023-10-09 20:09:10 +08:00 |