Hongze Cheng
430da1f872
enh: add memory usage monitor for vnode ( #31212 )
2025-05-27 16:40:03 +08:00
Haojun Liao
11665b6efe
fix(stream): control the global parameters.
2025-05-23 14:36:20 +08:00
Haojun Liao
8b2eb18323
fix(stream): update the stream info for update.
2025-05-23 11:01:28 +08:00
Haojun Liao
02d70186d2
refactor(stream): add parameters to config the stream queue size.
2025-05-22 19:56:49 +08:00
Haojun Liao
f5db6532dc
refactor(stream): add parameters to config the write queue size.
2025-05-22 19:54:54 +08:00
Haojun Liao
4743cc3683
refactor(stream): check for write queue size for sink tasks.
2025-05-22 17:55:47 +08:00
Haojun Liao
231d8b416e
fix(stream): fix memory leak.
2025-05-22 09:55:18 +08:00
WANG MINGMING
40216c6143
opti(tmq): save tmq offset in vnode commit time & change log level ( #30993 )
2025-05-15 18:15:01 +08:00
Haojun Liao
d02b17be0e
fix(stream): extends the node update check interval. ( #31048 )
2025-05-14 10:15:17 +08:00
Hongze Cheng
0dfb4596fb
enh: add another recover mode ( #30985 )
2025-05-12 11:28:07 +08:00
Haojun Liao
e439569455
test(stream): update the test cases. ( #31044 )
2025-05-12 11:25:07 +08:00
Jing Sima
84016904ff
fix: [TS-6445] Fix virtual tables not detecting schema changes. ( #30999 )
...
Ensure virtual tables invalidate cached schema metadata and reload it when a schema change (e.g., ALTER VTABLE) is detected. This prevents stale schema references and query errors after structural updates.
2025-05-10 10:34:54 +08:00
dongming chen
28fda620c7
feat: add tsRoutineReportInterval and integrate into syncNodeTimerRou… ( #30956 )
2025-05-09 09:16:49 +08:00
Kaili Xu
b88ec2f1a8
fix: timeseries statis for virtual table ( #30911 )
2025-04-27 18:03:20 +08:00
Hongze Cheng
de110f95ef
fix: invalid parameter input ( #30873 )
2025-04-24 20:02:52 +08:00
WANG MINGMING
ddd32e23d9
fix(tmq): init tmq handle error if snapshotVer is out of range ( #30859 )
2025-04-24 09:50:51 +08:00
WANG MINGMING
88eec0cddd
fix: (TS-6376)jump virtual table if snapshot is true in tmq ( #30835 )
2025-04-19 17:39:36 +08:00
WANG MINGMING
ca724865b9
fix(stream): parName is null ( #30592 )
2025-04-19 10:26:32 +08:00
Zhixiao Bao
1ae6b32541
fix: S3 data not being uploaded as expected.
2025-04-18 18:16:39 +08:00
Zhixiao Bao
6748fe8235
enh: reduce the amount of logs printed when the apply queue is full. ( #30796 )
2025-04-16 15:59:03 +08:00
Hongze Cheng
7e17430796
fix: make duplicate version acceptable ( #30794 )
2025-04-16 15:52:59 +08:00
Jing Sima
82b068ef8a
feat: [TS-6333] Fix decimal attempting free on address which was not malloc()-ed. ( #30764 )
2025-04-15 10:58:28 +08:00
Haojun Liao
a90b41e4ce
fix: tables with a composite primary key of type varchar may have incorrect counts of projected results when sorted.
2025-04-11 15:44:34 +08:00
Hongze Cheng
f4e210c452
fix: meta abort clear cache ( #30672 )
2025-04-08 18:21:57 +08:00
Hongze Cheng
0609bf14e6
fix: add tag data type check when create child table ( #30694 )
2025-04-08 17:42:06 +08:00
Zhixiao Bao
c64bea8b7f
fix(compact): unmatched parameter list. ( #30660 )
2025-04-07 17:05:58 +08:00
Bomin Zhang
a031d3ddd4
fix[TD-34340]: enable page recyling and ensure TDB cell size is at least the size of a free cell ( #30606 )
2025-04-03 13:28:09 +08:00
WANG MINGMING
1c4507ab75
fix(stream): row size error ( #30330 )
2025-03-28 18:10:57 +08:00
Jing Sima
f84f04398d
fix: [TS-4897] Support query stables cross databases and fix potential deadlock. ( #30507 )
2025-03-28 10:07:08 +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
Jing Sima
410324746b
feat:[TS-4897] virtual table ( #30098 )
...
* feat: [TS-4897] Support create/drop/alter/show/describe vtable
* feat: [TS-4897] Support vtable's query
* feat: [TS-4897] Support create virtual supertable
* feat: [TS-4897] Support explain analyze / where / count(*) and only select ts of vtable.
* feat: [TS-4897] Add create test and fix bugs
* feat: [TS-4897] Add alter/drop test and fix bugs
* feat: [TS-4897] Add describe/show test and fix bugs
* feat: [TS-4897] Add auth test and fix bugs
* feat: [TS-4897] Fix meta/catalog/cache bugs
* feat: [TS-4897] Support select tag from virtual child table
* feat: [TS-4897] Add select test and fix plenty of bugs
* feat: [TS-4897] Add optimize rule for vtable scan / support create vtable cross database / remove enterprise constraint / fix bugs.
* feat: [TS-4897] Fix 'schema is old'
* feat: [TS-4897] Support virtual stable query
* feat: [TS-4897] Add tests and Fix bugs
* feat: [TS-4897] resolve conflict.
2025-03-15 14:10:46 +08:00
