Commit graph

17631 commits

Author SHA1 Message Date
wangmm0220
dd8665a582 feat(stream): add skey/ekey/order for trigger 2025-07-01 17:34:00 +08:00
wangmm0220
4d6261bb04 Merge branch 'feat/TS-6100-3.0' of https://github.com/taosdata/TDengine into feat/TS-6100-3.0-mm 2025-07-01 13:53:39 +08:00
wangmm0220
138c2e41c3 feat(stream): fix coredump if do not set colId for triggerBlock with pseduCols 2025-07-01 11:20:09 +08:00
dapan1121
02106406f4 fix: memory free issue 2025-07-01 10:54:17 +08:00
Jinqing Kuang
2b0479a339 fix(stream): fix trigger check of virtual tables 2025-07-01 10:54:17 +08:00
wangmm0220
6f9077f95f feat(stream): add log 2025-07-01 10:17:07 +08:00
WANG MINGMING
3e0e339985
feat(stream): fix thread run out for runner (#31559) 2025-07-01 08:43:11 +08:00
Pan Wei
5e9606f5bb
fix: memory issues (#31561)
* enh: add operator reset func

* fix: merge join reset issue

* fix: memory issues
2025-07-01 08:38:36 +08:00
facetosea
1064dbe38a fix: fill 2025-06-30 17:34:39 +08:00
wangmm0220
5610088604 fix(stream): add log 2025-06-30 14:13:54 +08:00
wangmm0220
602de9eb87 feat(stream): fix datablockId not match in filter for calc 2025-06-30 10:21:50 +08:00
WANG MINGMING
8fba6e71c0
Merge pull request #31529 from taosdata/feat/TS-6100-3.0
Feat/ts 6100 3.0
2025-06-28 15:47:27 +08:00
wangmm0220
209922b7c4 feat(stream): fix rtInfo is null when fetch data in reader 2025-06-28 15:46:33 +08:00
facetosea
df2fedac4d fix: calc time range 2025-06-28 15:29:17 +08:00
Pan Wei
07c12a62dc
Merge pull request #31526 from taosdata/feat/TS-6100-3.0.pw9
fix: crash issues
2025-06-28 15:25:17 +08:00
wangmm0220
c0de4b1a73 feat(stream): fix logic error 2025-06-28 15:24:08 +08:00
wangmm0220
272e7e476b feat(stream): fix error if calc data 2025-06-28 14:25:29 +08:00
Pan Wei
2c589c2426
Merge branch 'feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9 2025-06-28 13:29:43 +08:00
dapan1121
130434d5c6 fix: crash issue 2025-06-28 13:24:58 +08:00
wangmm0220
564d585619 feat(stream): fix err that no rtInfo in stream fetch 2025-06-28 11:47:31 +08:00
dapan1121
13cf94addb fix: drop snode issue 2025-06-28 10:41:57 +08:00
WANG MINGMING
b047463a92
Merge branch 'feat/TS-6100-3.0' into feat/TS-6100-3.0-mm 2025-06-28 10:06:04 +08:00
wangmm0220
8858ebc250 feat(stream): optimize code 2025-06-28 10:02:32 +08:00
wangmm0220
6b08a4edd6 feat(stream): fix condition if %%trows 2025-06-27 19:37:02 +08:00
wangmm0220
c15deb10fe feat(stream): fix condition if %%trows 2025-06-27 19:32:26 +08:00
dapan1121
21f8fd2518 fix: remove assert 2025-06-27 17:52:30 +08:00
facetosea
32dcf48b17 fix: runner get data finished 2025-06-27 17:40:39 +08:00
dapan1121
deb16a0639 Merge remote-tracking branch 'origin/feat/TS-6100-3.0.001' into feat/TS-6100-3.0.pw9 2025-06-27 14:24:00 +08:00
dapan1121
b9159a570d Merge remote-tracking branch 'origin/3.0' into feat/TS-6100-3.0 2025-06-27 14:06:16 +08:00
dapan1121
b6e07d7cb5 fix: reader crash issue 2025-06-27 13:44:23 +08:00
Jinqing Kuang
e801487855 fix(stream): remove global calc request limit 2025-06-27 11:21:41 +08:00
dapan1121
1d8c4eb642 fix: add debug log 2025-06-27 09:49:15 +08:00
dapan1121
0a3454fd1a fix: add streamName 2025-06-27 09:34:42 +08:00
dapan1121
b70808214a Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9 2025-06-27 09:34:15 +08:00
dapan1121
eb851060e4 fix: error log 2025-06-27 08:14:05 +08:00
dapan1121
e6645c2e74 fix: crash issue 2025-06-27 07:58:46 +08:00
dongming chen
2678511dad
feat: add password encryption algorithm support and related configura… (#31237) 2025-06-27 07:58:32 +08:00
wangmm0220
5bf462d11f feat(stream): fix err if non table scan in calc plan 2025-06-26 15:58:08 +08:00
wangmm0220
01716fa4a0 feat(stream): last ver in wal 2025-06-26 15:42:29 +08:00
dapan1121
f47fbdd39e Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9 2025-06-26 13:58:59 +08:00
wangmm0220
5b60179ca1 feat(stream): modify blockIs in calcaCachaePlan & ver 2025-06-26 13:43:00 +08:00
dapan1121
348ccdd4ac Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9 2025-06-26 10:15:28 +08:00
dapan1121
363c808be0 fix: crash issue 2025-06-26 10:14:50 +08:00
dapan1121
eb8150b6fc Merge remote-tracking branch 'origin/feat/TS-6100-3.0.pw9' into feat/TS-6100-3.0 2025-06-26 07:58:03 +08:00
dapan1121
a42ed39535 enh: undeploy 2025-06-26 07:57:17 +08:00
wangmm0220
253f65b4f0 feat(stream): fix coredump when processing tag in reader 2025-06-25 19:07:12 +08:00
wangmm0220
e749ed09a3 feat(stream): checkpoint 2025-06-25 18:00:08 +08:00
Jinqing Kuang
34b2fb95a3 fix(stream): fix sliding offset in trigger deploy msg 2025-06-25 15:49:12 +08:00
Minglei Jin
66c4ef3e90
feat(mqtt): mqtt subscription (#30127)
* feat(mqtt): Initial commit for mqtt

* chore(xnode/mnd): xnode message handlers for mnode

* chore(mnd/xnode): mnode part for xnode

* chore(xnode/translater): fix show commands

* fix(ast/creater): fix xnode create option

* fix(xnode/ci): fix ci & doc's error codes

* chore(xnode/sql): make create/drop/show work properly

* fix(xnode/sql): commit new files

* fix(xnode/sql): commit cmake files

* fix: fix testing cases

* fix(xnode/tsc): fix tokens

* fix(ast/anode): fix anode update decl.

* fix(xnode/error): fix xnode error codes

* fix: xnode make/destroy

* chore: xnode with option & dnode id

* chore: use taosmqtt for xnode

* chore: new error code for xnode launching

* chore(xnode): new error code

* chore: header for _xnode_mgmt_mqtt

* chore: source for _xnode_mgmt_mqtt

* chore: remove test directory from cmake

* chore: remove taosmqtt for ci to compile

* chore: remove taosudf header from xnode

* chore: new window macro

* chore: remove xnode mgmt mqtt for windows compilation

* Revert "chore: remove xnode mgmt mqtt for windows compilation"

This reverts commit 197e1640c7.

* chore: cleanup code

* chore: xnode mgmt comment windows part out

* chore: mgmt/mqtt, move uv head toppest

* xnode/mnode: create xnode once per dnode

* fix(xnode/systable/test): fix column count

* xnode/sdb: renumber sdb type for xnode to make start/stop order correct

* xnode/mqtt: new param mqttPort

* fix SXnode's struct type

* transfer dnode id to mqtt subscription

* tmqtt: remove uv_a linking

* tmqtt/tools: sources for tools

* tools: fix windows compilation

* tools/producer: fix windows sleep param

* tools/producer: fix uninited var rc

* make tools only for linux

* test/mnodes: wail 1 or 2 seconds for offline to be leader

* update topic producer tool for geometry data type testing

* format tool sql statements

* show xnodes' ep

* make shell auto complete xnodes

* use usleep instead of sleep

* mqtt/proto: first version mqtt protocol

* remove assert styles

* build with linux only

* fix libuv for taosmqtt building

* fix log printing

* mem: use ttq_ prefix instead of tmqtt

* xnode/parser/proto: protocol option for xnode

* xnode/translater/option: translate xnode option proto

* xnode/translator: translate proto param

* xnode/tmsg: encode/decode proto param

* xnode/mnode: proto parma for mndXnode

* xnode/proto: protocol param for xnode

* xnode/mqtt: save/load proto from xnode json

* rename tmqtt proto header

* rename head directories

* rename header name styles

* restyle func names

* update

* update

* use camel db

* use camel for cxt

* update count of information_schema

* fix exceptional cases

* fix w.r.t reviews

* fixes w.r.t reviews

* use ttq_free

* append xnode msgs

* update information schema count

* support tmq meta data sub

* success typo fix

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* fix error line var w.r.t. suggestions from copilot

* denote mqtt node with bnode instead of xnode

* smoke testing for mqtt

* soak testing

* new package for test framework: paho 2.1.0

* import mqtt into util

* fix soak testing

* test/soak: user 5 topics per client

* test/soak: cover qos

* update docker image references to tdengine-ci:0.1 in CI scripts and common.py

* refactor: rename bnode msg to backup node

* refactor: rename xnode to bnode 1

* refactor: rename xnode to bnode 2

* refactor: rename xnode to bnode 3

* refactor: rename xnode to bnode 4

* refactor: rename xnode to bnode 4

* refactor: rename xnode to bnode 5

* refactor: rename xnode to bnode 6

* refactor: rename some files 1

* refactor: rename some files 2

* refactor: rename some files 3

* refactor: rename some files 4

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
Co-authored-by: chenhaoran <haoran920c@163.com>
Co-authored-by: Simon Guan <guanshengliang@qq.com>
2025-06-25 14:58:51 +08:00
dapan1121
d31dadb534 Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9 2025-06-25 11:04:32 +08:00