dapan1121
d6eb7151bf
fix: debug log issue
2025-05-06 18:51:40 +08:00
dapan1121
7af00e7330
fix: plan clone issue
2025-05-06 18:51:40 +08:00
yihaoDeng
e83c59fed9
feat(strea): add reader logic for calc
2025-05-06 18:10:40 +08:00
dapan1121
aeb53e88ae
fix: runner snode addr issue
2025-05-06 16:10:44 +08:00
dapan1121
88599ad4e7
enh: add drop stream processing
2025-05-06 10:27:12 +08:00
dapan1121
2dd6d3eb28
enh: add drop stream processing
2025-04-30 18:39:59 +08:00
dapan1121
2dadaf6f52
fix: add stream addr
2025-04-29 19:22:55 +08:00
dapan1121
c7c0d9e8b0
fix: stream vgroup map issue
2025-04-29 17:03:52 +08:00
dapan1121
2d499c9572
fix: stream queue issue
2025-04-29 15:32:56 +08:00
Jing Sima
6ae805bb7a
feat: [TS-6100] Process SCMCreateStreamReq ver-4
...
support placeHolderBitmap and interval offset in stream trigger.
remove useless code.
2025-04-29 15:19:30 +08:00
dapan1121
7f5cd8a70d
fix: add stream id
2025-04-29 13:59:53 +08:00
dapan1121
b07fafa27f
fix: stream hb rsp length issue
2025-04-29 11:02:56 +08:00
dapan1121
706d297232
fix: msg encode issues
2025-04-29 08:38:03 +08:00
dapan1121
ef1e51e9b9
enh: add stream obj name
2025-04-29 08:38:03 +08:00
dapan1121
87c8b3f8b7
fix: add stream phase
2025-04-29 08:38:03 +08:00
dapan1121
0c7504944f
fix: add hb processing
2025-04-29 08:38:03 +08:00
dapan1121
992042cd00
fix: compile issues
2025-04-27 18:36:08 +08:00
dapan1121
3793eb2835
enh:add hb msg serilization
2025-04-27 17:53:12 +08:00
dapan1121
cc025dbd59
enh: add task plan update
2025-04-25 14:59:41 +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
Jing Sima
c1cb4029a1
feat: [TS-6100] Build create request for create stream.
2025-04-21 17:47:15 +08:00
dapan1121
21e5aae05c
enh: add stream hb processing
2025-04-19 18:58:51 +08:00
dapan1121
279595240e
enh: add deploy processing
2025-04-18 19:28:43 +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
dapan1121
b5b9ba0faa
enh: add mnode processing
2025-04-14 13:20:57 +08:00
dapan1121
45d0af0a63
enh: add create stream
2025-04-10 19:41:37 +08:00
dapan1121
675790a63c
fix: remove codes
2025-04-10 09:09:30 +08:00
Simon Guan
9a89db55ca
enh: allow ordinary users to execute the “show anodes” command. ( #30464 )
2025-03-25 20:17:16 +08:00
dongming chen
13475700c5
enh: [TD-34190] remove-wrong-log ( #30408 )
2025-03-25 12:37:20 +08:00
Haojun Liao
af06bea439
fix(stream): add start/stop message. ( #30400 )
2025-03-24 19:38:00 +08:00
Haojun Liao
cfcdfdd2e7
fix(stream): update the update node info. ( #30364 )
2025-03-24 10:18:06 +08:00
Haojun Liao
82ffeb82a9
fix(gpt): fix the bug for algo name case sensitive ( #30362 )
2025-03-23 13:20:24 +08:00
Simon Guan
e5a1539c6d
Merge pull request #30307 from taosdata/fix/TS-5467-3.0
...
fix(stream): fix stream processing for virtual tables
2025-03-20 22:24:45 +08:00
liuyao
f7beaeebfe
ci: adjust test && fix issue
...
ci: adjust test && fix issue
2025-03-20 17:54:20 +08:00
Zhixiao Bao
0b8bff92c6
enh: add keep option while show stable. ( #30294 )
2025-03-20 15:30:22 +08:00
Haojun Liao
cd10173454
fix(gpt): fix error in gpt ( #30275 )
...
* fix(stream): support packaging enterprise edition.
* feat(gpt): support lstm and do some internal refactor, add sample autoencoder model.
* feat(gpt): support lstm and do some internal refactor, add sample autoencoder model.
* test(gpt): disable model case.
* test(gpt): disable model case.
* doc: fix title error in doc.
* doc: add mlp doc.
* fix(gpt): add gpt
* fix(gpt): update the test cases.
* fix(gpt): update the test cases.
* test(gpt): disable gpt test in github action.
* fix(gpt): check the grant, check the rsp code.
* fix(gpt): limit the forecast rows.
* fix(gpt): use default gpt service
* fix(gpt): update error code.
2025-03-20 15:18:58 +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
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
WANG MINGMING
3bc6635de3
feat[TS-6115]: support deletion of topics with active consumers. ( #30232 )
...
* feat[TS-6115]: drop topic & consumer group in force
* feat[TS-6115]: drop topic & consumer group in force
* feat[TS-6115]: drop topic & consumer group in force
2025-03-18 14:11:00 +08:00
Simon Guan
cf8d7cd0ac
Merge branch 'main' into merge/mainto3.0
2025-03-17 21:42:42 +08:00
Yihao Deng
2151c5cae0
update telemInterval ( #29703 )
2025-03-17 17:42:24 +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
