Commit graph

2415 commits

Author SHA1 Message Date
WANG MINGMING
7394319536
fix(taosd): add logic in altering table for tmq/stream (#34809) 2026-03-21 11:38:22 +08:00
dapan1121
42f03e896a Merge remote-tracking branch 'origin/main' into merge/mainto3.0 2026-03-20 09:58:36 +08:00
WANG MINGMING
6b890c396f
fix(tmq): client does not poll data in a long time if there are some exceptions in channel (#34852) 2026-03-19 17:11:13 +08:00
Yihao Deng
9d746e0730
fix compile error (#34803) 2026-03-17 13:49:08 +08:00
Yihao Deng
4c94cbe5da
enh: add safefunc (#34436) 2026-03-16 20:27:15 +08:00
Simon Guan
b8f11c5912 fix: conflicts 2026-03-12 09:41:15 +08:00
WANG MINGMING
30e3a46b8a
fix(taosc): optimize the speed of updating table lists when altering tags in tmq (#34711) 2026-03-11 14:08:27 +08:00
WANG MINGMING
f2bae7e798
enh(tmq): support for vtable (#34587) 2026-03-09 10:49:14 +08:00
Simon Guan
08007692be fix: conflicts 2026-03-04 14:44:07 +08:00
qevolg
e158512e58 Merge branch '3.3.8' into merge/3.3.8tomain 2026-02-28 16:50:17 +08:00
Simon Guan
d68acc8e10 fix: conflicts 2026-02-28 09:53:04 +08:00
WANG MINGMING
5e01b487e8
enh(tmq): remove pHandle when registering new pHandle (#34586) 2026-02-28 09:42:47 +08:00
WANG MINGMING
a44a2a12a1
enh(tmq): optimize logic of tmq of query (#34303) 2026-02-26 17:06:07 +08:00
wangmm0220
893f1b431e fix(merge): conflict from 338 2026-02-03 23:51:41 +08:00
wangmm0220
6e705db306 enh(taosd): merge from 3.3.6 2026-02-03 16:50:09 +08:00
WANG MINGMING
b248f7fc77
opti(tmq): update tablelist if alter tag in tmq (#34483) 2026-02-03 16:19:21 +08:00
wangmm0220
0de0ffd04e enh(tmq): merge from 3.3.6 2026-02-02 19:12:35 +08:00
WANG MINGMING
c50f0033bb
enh(tmq): optimize update tablelist for topic of stable with filter when alter tag (#34417) 2026-02-02 16:38:12 +08:00
Simon Guan
60d797cdcf fix: conflicts 2025-12-23 15:31:08 +08:00
wangmm0220
25ac12c1df fix(tmq): merge from 3.3.6 2025-12-22 18:47:59 +08:00
WANG MINGMING
9cf0850bf2
fix(tmq): optimize tablelist in tmq when alter tag & modify tag if ne… (#33988) 2025-12-22 18:14:39 +08:00
WANG MINGMING
94b5adcd3b
fix(tmq): pSw is null if get raw data & remove consumer is not ready status (#33945) 2025-12-22 09:15:44 +08:00
WANG MINGMING
79a5c48ffa
feat(tmq): [TS-6379]remove limition for table operation in tmq (#33834) 2025-12-15 11:26:46 +08:00
Simon Guan
4bd57b4c2d merge: from main .to 3.0 branch 2025-12-10 16:09:36 +08:00
WANG MINGMING
00e27e31c9
fix(tmq): race condition in tmq snapshot for data transformation (#33691) 2025-12-08 14:03:20 +08:00
dongming chen
643dfcb4fc
feat(TS-7270): encrypt algr (#33783) 2025-12-05 13:26:28 +08:00
Simon Guan
9e65ae2c6f Merge branch '3.3.6' into merge/3.3.6tomain 2025-11-19 17:52:58 +08:00
WANG MINGMING
3713359f19
fix(tmq): [TS-7662] fix getting more creating table message because o… (#33639) 2025-11-19 17:31:16 +08:00
wangmm0220
d29bb66323 enh(stream): fix conflicts; 2025-11-15 19:00:42 +08:00
Simon Guan
fec690899e
merge: from 3.3.6 to main branch #33572 2025-11-14 10:11:01 +08:00
wangmm0220
067dfda7db enh(stream): break out in processTs if reader is turnned off 2025-11-13 15:32:51 +08:00
xiao-77
e004167333 Merge remote-tracking branch 'origin/3.3.6' into merge/3.3.6tomain 2025-11-13 11:07:32 +08:00
WANG MINGMING
1ced706b9d
enh(wal): [TS-7567]set wal keep version to avoid deleting (#33517) 2025-11-13 09:28:26 +08:00
wangmm0220
3f7d2702f7 enh(stream): fix errors in ci 2025-11-11 13:48:35 +08:00
wangmm0220
a6cb6d4266 enh(stream): fix errors in ci 2025-11-11 11:20:49 +08:00
Simon Guan
eb90b38991 Merge branch '3.3.6' into merge/3.3.6tomain 2025-11-06 16:35:52 +08:00
WANG MINGMING
101c8c6745
feat(taos): add connector info for perf_connections (#33458) 2025-11-05 17:48:58 +08:00
Simon Guan
9ff816a9a7 merge: fix conflict 2025-10-10 10:35:28 +08:00
Simon Guan
ac0535eb41 Merge branch '3.3.6' into merge/3.3.6tomain 2025-10-10 10:31:04 +08:00
WANG MINGMING
6381321865
fix(tmq): [ts7402]tag filter do not work if topic is stable with filter (#33143) 2025-10-10 09:30:45 +08:00
WANG MINGMING
482cc5392e
fix(tmq): [ts7402]tag filter do not work if topic is stable with filter (#33191) 2025-10-10 09:30:37 +08:00
Kaili Xu
13ae5350b7
feat: rollup sma (#33063) 2025-09-26 17:32:32 +08:00
WANG MINGMING
7cf8b26a0e
fix(stream): auto create normal table error in tmq (#32861) 2025-09-05 10:23:02 +08:00
Haojun Liao
87524f9695
fix(query): set the alias name for _select_value if it is only the parameter of some functions. (#32704) 2025-08-25 16:35:20 +08:00
Haojun Liao
b225181dd7
fix(stream): handle source/destination table schema change scenearios. (#32580)
* fix(stream): handle source/destination table schema change scenearios.

* test(stream): update test cases.
2025-08-15 11:33:25 +08:00
WANG MINGMING
1a184804e3
fix(tmq): open asan (#32489) 2025-08-11 10:46:40 +08:00
Simon Guan
34cb3e07ca Merge branch '3.3.6' into merge/3.3.6tomain 2025-08-07 12:01:55 +08:00
WANG MINGMING
30bc5b09e5
fix(tmq): [td-37265]poll error if insering some cols with stmt (#32438) 2025-08-06 17:34:26 +08:00
Yihao Deng
904378322f
fix: blob test (#32020)
* fix blob query error

* fix blob query error

* fix blob query error

* fix blob query error

* fix blob query error

* opt query

* opt write

* opt write

* opt write

* opt bse

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* opt write

* add cache

* opt query

* opt query

* opt bse

* add data iter

* add data iter

* add more compress

* add more compress

* add more compress

* add more compress

* add more compress

* add more compress

* opt blob transfer

* opt blob transfer

* opt blob transfer

* opt write

* avoid unordered data write

* avoid unordered data write

* opt read

* refactor log

* fix invalid write

* refactor code

* fix merge error

* fix merge error

* add error code

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* support blob type len

* Merge remote-tracking branch 'origin/3.0' into enh/blob

* refactor code

* support blob type len

* refactor code

* refactor code

* benchmark support blob type

* benchmark support blob type

* add log

* handle sort and merge row

* change file set

* change file set

* change file set

* change file set

* change file set

* change file set

* change file set

* opt code

* opt read

* add restart error and add unit test

* add restart error and add unit test

* add restart error and add unit test

* add restart error and add unit test

* add restart error and add unit test

* refactor code

* add restart error and add unit test

* opt code

* refactor code

* fix invalid write

* blob test

* blob test

* blob test

* blob test

* blob test

* support blob

* add str trim

* add str trim

* Merge remote-tracking branch 'origin/3.0' into feat/blob

* Merge remote-tracking branch 'origin/3.0' into feat/blob

* update test case

* fix invalid read

* fix invalid read

* fix invalid read

* add stmt2

* add stmt2

* add stmt2

* update parameter

* refactor test case

* refactor test case

* support blob

* support stmt2

* add sub

* support blob

* support blob

* support sub

* fix tmq crash

* support windows/darwin

* fix stmt2 bind row

* fix blob crash

* fix blob crash

* fix blob query error

* fix blob crash

* fix merge error

* refactor bse

* add blob transfer

* add blob transfer

* add transfer snapshot

* refactor code

* change log level

* change log level

* add test case

* refactor code

* revert taosBenchmark

* revert taosbench

* fix: improve error handling and encoding for file reading in grep_asserts_in_file function

* rm assert

* fix mem leak

* fix compile error

* fix conflict

* fix conflict

* fix compile error

* fix compile error

* fix pre check error

* fix pre check error

* fix compile error on windows

* fix error on window

* fix error on windows

* fix error on windows

* opt no-blob sql

* fix compile error on dawain

* fix compile error on dawain

* fix invalid read

* fix mem leak

* fix invalid read

* fix invalid read

* fix error on windows

* remove unused code

* refactor code

* fix mem leak

* fix mem leak

* rm unused code

* rm unused code

* fix invalid copy

* fix invalid copy

* fix invalid copy

* fix invalid copy

* fix invalid copy

* refactor code

* make ci happy

* refactor code

* change make

* update test case

* update ignore code

* update bse snapshot and test case

* update bse snapshot and test case

* refactor code

* change unit test

* update bse snapshot

* update bse snapshot

* fix test case

* fix bse snapshot

* fix bse snapshot

* fix snapshot transfer

* remove unused log

* support func query

* add test case

* forbidden  unsupport code

* merge 3.0

* merge 3.0

* change test case

* add forbidden code

* add forbidden code

* add code

* support length func

* support length func

* taosBenchmark support  blob

* support blob raw block

* support write raw block

* support more query

* Merge branch 'feat/blob' into feat/blob_test

* SBlobRow2

* change bse commit change

* refactor code

* rm exe test

* refactor code

* checke return code

* rename blob name

* refactor code

* refactor code

* refactor code

* refactor code

* fix unordere write

* fix unordere write

* fix row merge error

* fix row merge error

* fix row merge error

* fix row merge error

* support ordered data

* support ordered data

* Merge remote-tracking branch 'origin/3.0' into feat/blob_test

* fix stmt2 blob crash

* add not support write type

* add not support write type

* add not support write type

* rm exe

* fix col-formate error

* fix col-formate error

* fix mem leak

* refactor code

* add error code for single blob column restriction and update error message

* add error code for single blob column restriction and update error message

* add error code for single blob column restriction and update error message

* refactor code

* change error code

* make ci happy

---------

Co-authored-by: yihaoDeng <yhdeng@taosdata.com>
Co-authored-by: chenhaoran <haoran920c@163.com>
2025-07-21 17:14:57 +08:00
Kaili Xu
799b3341de
enh: mounted vnode may have no tq (#31916) 2025-07-19 09:12:12 +08:00