Jinqing Kuang
1c71c8ce40
fix(stream): fix wal meta datablock of stream reader task
2025-05-06 18:46:14 +08:00
yihaoDeng
209fa90b34
feat(strea): add reader logic for calc
2025-05-06 18:05:47 +08:00
wangmm0220
bd8188c533
fix(stream): add error code if no data in block
2025-05-06 09:43:20 +08:00
wangmm0220
8d9a2b1c56
feat(stream): add logic for stream reader
2025-04-30 18:08:08 +08:00
wangmm0220
2236273044
feat(stream): add logic for stream reader
2025-04-30 17:39:14 +08:00
wangmm0220
10d955528a
feat(stream): add logic for stream reader
2025-04-30 13:37:48 +08:00
wangmm0220
ae43f9023d
feat(stream): remove useless code
2025-04-30 09:14:19 +08:00
wangmm0220
145a535e12
feat(stream): remove useless code
2025-04-30 09:12:20 +08:00
wangmm0220
19a878cc79
feat(stream): add thread worker for stream reader
2025-04-29 18:51:21 +08:00
wangmm0220
0b861a2c7c
feat(stream): add thread worker for stream reader
2025-04-29 16:28:33 +08:00
WANG MINGMING
be7fffcde4
Merge branch 'feat/TS-6100-marks-new' into feat/TS-6100-3.0
2025-04-29 15:05:38 +07:00
wangmm0220
37a315fcc7
feat(stream): add thread worker for stream reader
2025-04-29 16:02:05 +08:00
Jinqing Kuang
162d083951
fix(stream): fix compile issues
2025-04-29 09:23:09 +08:00
wangmm0220
5d13d3a4ce
feat(stream): add logic of stream reader
2025-04-28 19:26:02 +08:00
wangmm0220
c632dcf0c1
feat(stream): add logic of stream reader
2025-04-28 19:21:47 +08:00
wangmm0220
a78b09577a
feat(stream): add thread worker for stream reader
2025-04-28 14:37:05 +08:00
wangmm0220
2a1a6d0d95
feat(stream): add thread worker for stream reader
2025-04-27 09:11:50 +08:00
wangmm0220
eee6456cc4
feat(stream): add thread worker for stream reader
2025-04-25 18:18:17 +08:00
dapan1121
cc025dbd59
enh: add task plan update
2025-04-25 14:59:41 +08:00
wangmm0220
5ce115cc23
feat(stream): fix compile error
2025-04-24 18:02:12 +08:00
dapan1121
330cf9982d
fix: compile issues
2025-04-24 09:11:54 +08:00
dapan1121
b8991295e1
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw1
2025-04-22 17:49:01 +08:00
dapan1121
ae0e1ded7d
enh: add hb processing
2025-04-22 17:46:17 +08:00
WANG MINGMING
c85b195421
Merge branch 'feat/TS-6100-marks' into feat/TS-6100-3.0
2025-04-19 16:18:09 +07:00
wangmm0220
80f368ba51
feat(stream): add stream reader logic
2025-04-19 17:10:43 +08:00
wangmm0220
919628568d
feat(stream): add stream reader logic
2025-04-17 19:50:37 +08:00
dapan1121
7c714f7d5f
Merge remote-tracking branch 'origin/feat/TS-6100-3.0.pw1' into feat/TS-6100-3.0
2025-04-17 10:48:44 +08:00
dapan1121
38bdafd329
enh: add deploy processing
2025-04-17 10:45:06 +08:00
wangjiaming0909
163dd33a0a
new-stream: impl stream runner
2025-04-16 18:16:55 +08:00
wangjiaming0909
22b1eebb3a
new-stream: define vnode build runner task
2025-04-16 18:16:55 +08:00
Haojun Liao
cfcdfdd2e7
fix(stream): update the update node info. ( #30364 )
2025-03-24 10:18:06 +08:00
Simon Guan
24d4f37f83
Merge branch '3.0' into merge/mainto3.0
2025-03-22 23:41:39 +08:00
Simon Guan
c00f876638
Merge branch 'main' into merge/mainto3.0
2025-03-22 23:41:35 +08:00
Hongze Cheng
9723fd9182
fix: send uninitialized memory ( #30328 )
2025-03-22 23:23:14 +08:00
Zhixiao Bao
ec7177cb7d
fix: correct numberFileset counting cause S3 retention happened while compact. ( #30282 )
2025-03-21 14:50:41 +08:00
Simon Guan
eff763dc91
fix(stream): fix stream processing for virtual tables
2025-03-20 22:31:29 +08:00
Simon Guan
2c27c10fa8
Merge branch 'main' into merge/mainto3.0
2025-03-20 14:05:45 +08:00
dapan1121
f0f517db71
fix: vnode vsubtables meta fetch issue
2025-03-20 09:52:03 +08:00
Jinqing Kuang
c82398e175
fix(stream): fix stream processing for virtual tables
...
- Fixed status check in virtual table stream processing
- Fixed multi-way merge logic for super virtual tables
- Fixed generation of target subtable names during merge
2025-03-20 01:15:54 +08:00
Haojun Liao
db57fc4ba8
fix(stream): fix race condition in send msg. ( #30277 )
...
Co-authored-by: 54liuyao <54liuyao@163.com>
Co-authored-by: Jinqing Kuang <kuangjinqingcn@gmail.com>
Co-authored-by: wangmm0220 <wangmm0220@gmail.com>
Co-authored-by: yihaoDeng <luomoxyz@126.com>
2025-03-19 23:15:15 +08:00
Simon Guan
0a96294056
fix: adjust raft logs ( #30258 )
2025-03-19 21:44:39 +08:00
Simon Guan
d02196a231
refactor: adjust some logs ( #30245 )
...
* refactor: adjust wal log infos
* refactor: adjust some log's level
* refactor: adjust some log's level
* fix: add traceId for sync module
* refactor: adjust log level
* refactor: adjust log level
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* docs: update keywords
* fix: compile errors in windows
* docs: minor changes
* docs: minor changes
* refactor: minor changes
* docs: fminro changes
* docs: format
* refactr: remove uncessory logs
* docs: format doc
2025-03-18 17:55:36 +08:00
Simon Guan
ddc05f168e
refactor: adjust the log to track the data writing process on the server via QID ( #30195 )
...
* refactor: adjust wal log infos
* refactor: adjust some log's level
* refactor: adjust some log's level
* fix: add traceId for sync module
* refactor: adjust log level
* refactor: adjust log level
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* refactor: adjust log levels
* fix: compile errors in windows
* refactor: minor changes
2025-03-18 16:21:44 +08:00
Simon Guan
7edd97a321
fix: compile errors
2025-03-17 22:57:06 +08:00
Simon Guan
87fbdd24ad
fix: compile errors
2025-03-17 22:54:12 +08:00
Simon Guan
cf8d7cd0ac
Merge branch 'main' into merge/mainto3.0
2025-03-17 21:42:42 +08:00
dongming chen
03fe3e5430
fix: [TD-34000] remove lock when send heartbeat reply main ( #30123 )
...
* fix(stream): reduce the consensus checkpoint id trans.
* refactor(stream): add some logs.
* refactor(stream): set the max checkpoint exec time 30min.
* refactor(stream): add checkpoint-consensus trans conflict check.
* refactor(stream): remove unused local variables.
* fix(stream): fix syntax error.
* fix(stream): 1. fix free memory error 2. continue if put result into dst hashmap failed.
* fix issue
* fix issue
* fix(mnd): follower mnode not processes the timer event.
* fix(stream): print correct error msg.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): truncate long subtable name
* fix(stream): add buffer len.
* refactor(stream): update some logs.
* fix issue
* refactor(stream): update some logs.
* refactor(stream): update some logs.
* fix(stream): check return value.
* fix(stream): fix syntax error.
* fix(stream): check return value.
* fix(stream): update the timer check in mnode.
* fix: TD-34000-remove-lock-when-send-heartbeat-reply
* fix: TD-34000-remove-lock-when-send-heartbeat-reply
---------
Co-authored-by: Haojun Liao <hjliao@taosdata.com>
Co-authored-by: 54liuyao <54liuyao@163.com>
Co-authored-by: Jinqing Kuang <kuangjinqingcn@gmail.com>
2025-03-17 17:13:54 +08:00
Haojun Liao
dfe32225de
chore: merge main.
2025-03-17 14:51:11 +08:00
Haojun Liao
ab92886820
fix(stream): reduce the consensus checkpoint id trans. ( #30105 )
...
* fix(stream): reduce the consensus checkpoint id trans.
* refactor(stream): add some logs.
* refactor(stream): set the max checkpoint exec time 30min.
* refactor(stream): add checkpoint-consensus trans conflict check.
* refactor(stream): remove unused local variables.
* fix(stream): fix syntax error.
* fix(stream): 1. fix free memory error 2. continue if put result into dst hashmap failed.
* fix issue
* fix issue
* fix(mnd): follower mnode not processes the timer event.
* fix(stream): print correct error msg.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): truncate long subtable name
* fix(stream): add buffer len.
* refactor(stream): update some logs.
* fix issue
* refactor(stream): update some logs.
* refactor(stream): update some logs.
* fix(stream): check return value.
* fix(stream): fix syntax error.
* fix(stream): check return value.
* fix(stream): update the timer check in mnode.
* fix(stream): add restart stage tracking.
* fix(stream): track the start task stage for meta.
* fix(stream): fix error in log.
* refactor(stream): adjust log info.
* fix mem issue
* fix(stream): check the number of required tasks for consensus checkpointId.
* fix(stream): lock the whole start procedure.
* fix(stream): add lock during start all tasks.
* fix(stream): update logs.
* fix(stream): update logs.
* fix(stream): update logs.
* fix(stream): fix dead-lock.
* fix(stream): fix syntax error.
* fix(stream): not drop the scan-history task.
* fix(stream): fix syntax error.
* fix(stream): wait for executor stop before restarting.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): add some logs.
* fix(stream): disable some logs.
* fix(stream): reset the start info if no task left.
---------
Co-authored-by: 54liuyao <54liuyao@163.com>
Co-authored-by: Jinqing Kuang <kuangjinqingcn@gmail.com>
2025-03-17 10:20:17 +08:00
Jinqing Kuang
ac23a4fc55
feat(stream): support stream processing for virtual tables ( #30144 )
...
* enh: add client processing
* enh: add mnode vtables processing
* enh: add mnode vtable processing
* enh: add normal child vtable support
* fix: compile issues
* fix: compile issues
* fix: create stream issues
* fix: multi stream scan issue
* fix: remove debug info
* fix: agg task and task level issues
* fix: correct task output type
* fix: split vtablescan from agg
* fix: memory leak issues
* fix: add limitations
* Update 09-error-code.md
* Update 09-error-code.md
* fix: remove usless case
* feat(stream): extract original table data in source scan task
Implemented functionality in the source task to extract data
corresponding to the virtual table from the original table using WAL.
The extracted data is then sent to the downstream merge task for further
processing.
* feat(stream): multi-way merge using loser tree in virtual merge task
Implemented multi-way merge in the merge task using a loser tree to
combine data from multiple original table into a single virtual table.
The merged virtual table data is then pushed downstream for further
processing. Introduced memory limit handling during the merge process
with configurable behavior when the memory limit is reached.
* fix(test): remove useless cases
---------
Co-authored-by: dapan1121 <wpan@taosdata.com>
Co-authored-by: Pan Wei <72057773+dapan1121@users.noreply.github.com>
2025-03-15 17:06:48 +08:00
