Pan Wei
bcc25e56bc
feat: new stream ( #31678 )
...
* fix: windows compile issue
* test: add vtable cases (#31829 )
* fix: windows compile issues
* test:add test cases
* fix: windows compile issue
* case: em-4 stream case submit
* test: stream4_sub1 found bug2
* test: submit test_scene_meters_bug2.py
* add stream parameters example
* feat: [TS-6100] Do not translate const value as column.
* Feat/ts 6100 3.0 zlv (#31747 )
* modify asan exampel
* modify asan exampel
* add example
* add example
* modify case example
---------
Co-authored-by: zelv01 <1101510017@qq.com>
* feat(stream): fix memory leak
* modify sliding example
* test: update test case.
* feat(stream): fix conflicts
* fix: add offset case 10a 10s 10m 10h 10d
* feat(stream): fix conflicts
* chore(stream): rename case name #TS-6100
* add case
* modify example
* fix: windows compile issues
* fix: data null check
* feat: [TS-6100] Forbid where when using %%trows (#31827 )
* feat: [TS-6100] Forbid where when using %%trows
* test: update cases
* feat: [TS-6100] Fix leaks.
---------
Co-authored-by: Simon Guan <guanshengliang@qq.com>
* test: reproduce bugs
* test: update test case.
* test: update test case.
* feat: [TS-6100] Fix leaks.
* test: add cases
* Feat/ts 6100 3.0.pw10 (#31841 )
* enh: add operator reset func
* fix: merge join reset issue
* fix: memory issues
* fix: add debug assert
* fix: memory issues
* fix: memory leak
* fix: memory issues
* fix taos log miss
* fix: case issue
* fix: case issue
* fix: case issues
* fix: drop dnode issue
* fix: memory issues
* fix: memory issues
* fix: memory leak issues
* fix: recalculate time range issue
* fix: add debug log
* fix: memory issues
* fix: enable case asan
* Update streamlist_for_ci.task
* fix: case asan issue
* fix: stream name issue
* fix: external window compile issues
* fix: deploy memory issue
* fix: ahandle issue
* fix: ahandle issue
* fix: ahandle issue
* fix: virtual table reader list issue
* fix: log info
* fix: msg error
* fix: virtual table addr list issue
* fix: memory issues
* fix: memory leak issue
* fix: memory issues
* fix: memory free issues
* fix: memory issues
* fix: snode deploy issue
* fix: mnode reader issue
* fix: memory issues
* fix: add debug test
* enh: add ignore nodata trigger
* fix: memory leaks
* fix: configuration issue
* fix: memory issue
* fix: external window issue
* fix: external window issues
* fix: external window placeholder issue
* fix: placeholder function init issues
* fix: memory leak issue
* fix: add debug log
* fix: compile issues
* fix: double free issue
* fix: runner addr update issue
* fix: msg rsp issue
* fix: external window reset issue
* fix: configuration issue
* fix: deploy msg issue
* fix: compile issue
---------
Co-authored-by: huohong <sallyhuo@taosdata.com>
* test: reproduce bugs
* fix: add sliding interval combine case
* test: add cases
* test: add recalc test.
* test: reproduce bugs
* case : add vt ts is null check
* modify case
* bug: submit test_idmp_meters_bug3.py
* test: add test for recalc.
* test: add cases
* fix: error code check
* test: add cases
* fix(stream): scan wal with schema in that version
* add case
* test: add cases
* test: update test case.
* fix: windows compile issues
* add case
* test: add cases (#31845 )
* modify case
* fix: reset interpPrev
* test: add test_idmp_meters bug4 and bug3
* add case
* fix(stream): opti wal interface
* fix: remove test_idmp_meters_bug5.py
* test: add cases
* fix(stream): fix ts data fetch for virtual tables
* cancel asan case
* test: update test case.
* test: update test case.
* add case
* test: add cases
* test: add cases
* test: add case test_idmp_meters_bug5.py
* test: update test case.
* fix(stream): tmq error
* test: add cases
* feat: [TS-6100] Restore deleted code in mndSma.c since they are still in use.
* fix(stream): optimize val scan logic
* test: add test_recalc_expired_time.py to ci.
* test: update test case.
* test: update test case.
* feat: [TS-6100] Fix fill range check
* fix(stream): optimize val scan logic
* add case
* test: modify for partition by %%1
* test: add fun case stream4_sub7
* fix(stream): optimize val scan logic
* add case
* feat: [TS-6100] Rename OPTIONS to STREAM_OPTIONS.
* test: add test for recalc.
* test: use stream_options.
* fix: some cases error.
* test: remove recalc from ci.
* fix: ci case issues (#31880 )
* enh: add operator reset func
* fix: merge join reset issue
* fix: memory issues
* fix: add debug assert
* fix: memory issues
* fix: memory leak
* fix: memory issues
* fix taos log miss
* fix: case issue
* fix: case issue
* fix: case issues
* fix: drop dnode issue
* fix: memory issues
* fix: memory issues
* fix: memory leak issues
* fix: recalculate time range issue
* fix: add debug log
* fix: memory issues
* fix: enable case asan
* Update streamlist_for_ci.task
* fix: case asan issue
* fix: stream name issue
* fix: external window compile issues
* fix: deploy memory issue
* fix: ahandle issue
* fix: ahandle issue
* fix: ahandle issue
* fix: virtual table reader list issue
* fix: log info
* fix: msg error
* fix: virtual table addr list issue
* fix: memory issues
* fix: memory leak issue
* fix: memory issues
* fix: memory free issues
* fix: memory issues
* fix: snode deploy issue
* fix: mnode reader issue
* fix: memory issues
* fix: add debug test
* enh: add ignore nodata trigger
* fix: memory leaks
* fix: configuration issue
* fix: memory issue
* fix: external window issue
* fix: external window issues
* fix: external window placeholder issue
* fix: placeholder function init issues
* fix: memory leak issue
* fix: add debug log
* fix: compile issues
* fix: double free issue
* fix: runner addr update issue
* fix: msg rsp issue
* fix: external window reset issue
* fix: configuration issue
* fix: deploy msg issue
* fix: compile issue
* fix: external window idx issue
* fix: ci issues
---------
Co-authored-by: huohong <sallyhuo@taosdata.com>
* fix(stream): fix compilation error
* fix(stream): optimize val scan logic
* test:add test cases
* test: modify case
* fix: external agg error
* test(stream): tobacco scene testing #TD-36514
* test: add stream cases (#31885 )
* fix: windows compile issue
* fix: calc timerange
* fix: windows compile issue
* modify case
* fix(stream): compile error
* test: remove one debug test case file
* test: modify
* test: add test cases
* test: reproduce bugs
* test: reproduce bugs
* feat: [TS-6100] Placeholder function should only appera in SELECT and… (#31868 )
* feat: [TS-6100] Placeholder function should only appera in SELECT and WHERE and FROM.
* test: update case
---------
Co-authored-by: Simon Guan <guanshengliang@qq.com>
* add example
* add example
* modify case example
* modify case
* test:alter sql
* test: add stream5 case
* fix(stream): get schema error with version
* test: add delete recalc test py.
* test: remove bug cases
* test: stream5 case test passed
* test: add state cases (#31893 )
* fix(stream): compile error
* test: modify case
* test: add cases
* test: add test.
* test: update test case.
* chore(test): fix case err
* test: update test case.
* fix: align data get
* fix(stream): fix row index of datablock written into data cache
* fix: put align data
* test: update test case.
* test: add test cases for virtual table
* chore(test): fix case err #TD-36514
* add case
* test: add test for water mark.
* test: add meters bug6 for stream5
* test: add cases (#31903 )
* test: add test for recalc.
* feat: [TS-6100] %%trows can only be used when event type is window close.
* test: add precision of database for ms/us/ns
* modify case
* add case
* add case
* test: add test to ci.
* modify case
* fix: ci case issues (#31904 )
* enh: add operator reset func
* fix: merge join reset issue
* fix: memory issues
* fix: add debug assert
* fix: memory issues
* fix: memory leak
* fix: memory issues
* fix taos log miss
* fix: case issue
* fix: case issue
* fix: case issues
* fix: drop dnode issue
* fix: memory issues
* fix: memory issues
* fix: memory leak issues
* fix: recalculate time range issue
* fix: add debug log
* fix: memory issues
* fix: enable case asan
* Update streamlist_for_ci.task
* fix: case asan issue
* fix: stream name issue
* fix: external window compile issues
* fix: deploy memory issue
* fix: ahandle issue
* fix: ahandle issue
* fix: ahandle issue
* fix: virtual table reader list issue
* fix: log info
* fix: msg error
* fix: virtual table addr list issue
* fix: memory issues
* fix: memory leak issue
* fix: memory issues
* fix: memory free issues
* fix: memory issues
* fix: snode deploy issue
* fix: mnode reader issue
* fix: memory issues
* fix: add debug test
* enh: add ignore nodata trigger
* fix: memory leaks
* fix: configuration issue
* fix: memory issue
* fix: external window issue
* fix: external window issues
* fix: external window placeholder issue
* fix: placeholder function init issues
* fix: memory leak issue
* fix: add debug log
* fix: compile issues
* fix: double free issue
* fix: runner addr update issue
* fix: msg rsp issue
* fix: external window reset issue
* fix: configuration issue
* fix: deploy msg issue
* fix: compile issue
* fix: external window idx issue
* fix: ci issues
* fix: ci case issues
* fix: drop dnode issue
---------
Co-authored-by: huohong <sallyhuo@taosdata.com>
* fix(stream): ci error
* test: update test case.
* feat: [TS-6100] Disable some failed UT.
* feat: [TS-6100] Fix virtual table
* test: add bug 5.
* test: add test delete recalc to ci.
* test: add bug 6.
* test(stream): tobacco scene #TD-36514
* fix: reqCids,reqCols memory leak in SSTriggerRealtimeContext
Co-authored-by: Tony Zhang <tonyzhang@taosdata.com>
* test: add case stream6
* fix(stream): implement some pending features in trigger task
* modify case
* modify case
* fix: case issues
* modify case
* test: add recalc for warter mark.
* fix(stream): fix count window trigger of virtual tables
* fix(stream): memory leak
* test: fix run err.
* test: add stream6 bug7
* fix: adjust format
* test(stream): tobacco scene testing #TD-36514
* test: change bug7 with update window1 and 2
* test: add test bug 7.
* case: restore write 3 window
* fix: windows compile issue
* fix: notify
* test: add cases
* modify case
* test: update test case.
* test(stream): toobacco scene testing #TD-36514
---------
Co-authored-by: Simon Guan <slguan@taosdata.com>
Co-authored-by: plum-lihui <huili@taosdata.com>
Co-authored-by: Alex Duan <417921451@qq.com>
Co-authored-by: zelv01 <1101510017@qq.com>
Co-authored-by: Jing Sima <simondominic9997@outlook.com>
Co-authored-by: xiangyang guo <66111494+happyguoxy@users.noreply.github.com>
Co-authored-by: wangmm0220 <wangmm0220@gmail.com>
Co-authored-by: Haojun Liao <hjliao@taosdata.com>
Co-authored-by: zyyang90 <zyyang@taosdata.com>
Co-authored-by: Alex Duan <51781608+DuanKuanJun@users.noreply.github.com>
Co-authored-by: facetosea <285808407@qq.com>
Co-authored-by: Simon Guan <guanshengliang@qq.com>
Co-authored-by: huohong <sallyhuo@taosdata.com>
Co-authored-by: Li Hui <52318143+plum-lihui@users.noreply.github.com>
Co-authored-by: Jinqing Kuang <kuangjinqingcn@gmail.com>
Co-authored-by: xiao-77 <berylbao@taosdata.com>
Co-authored-by: Zhixiao Bao <62235797+xiao-77@users.noreply.github.com>
Co-authored-by: happyguoxy <happy_guoxy@163.com>
Co-authored-by: Tony Zhang <34825804+Tony2h@users.noreply.github.com>
Co-authored-by: Tony Zhang <tonyzhang@taosdata.com>
2025-07-16 14:42:16 +08:00
Jinqing Kuang
51ffff2079
feat(query)[TS-5470]: add syntax to specify minimum duration for event and state windows
...
Introduce the `true for` syntax to allow users to specify the minimum
duration for event and state windows. Add corresponding tests to
validate the feature. Updated the user manual with usage instructions.
2025-02-24 08:02:48 +08:00
Shengliang Guan
4dc0c2f47e
feat: data analysis
2024-10-09 17:09:43 +08:00
Jing Sima
8d02e3e310
fix:[TD-32310] Avoid access null pointer when error occurs..
2024-09-25 11:15:48 +08:00
Jing Sima
122b707ac8
enh:[TD-32158] Free memory allocated in function setup.
2024-09-24 11:35:36 +08:00
Jing Sima
23b525458e
fix:[TD-32262] Avoid mem leak when error occurs.
2024-09-23 13:50:55 +08:00
Haojun Liao
0236db51f6
fix(query): fix memory leak and do some internal refactor.
2024-09-06 15:44:25 +08:00
lyh250-666
9c8f630759
enh:modify error code passing in libs/executor/
2024-09-03 11:01:02 +08:00
xsren
d43df78537
fix: free operator
2024-08-29 19:43:59 +08:00
Haojun Liao
c118df0ec4
fix(query): fix memory leak.
2024-08-27 17:04:44 +08:00
54liuyao
939342b3de
fix(query):seset group id for the results of event and count operators
2024-08-22 11:11:40 +08:00
54liuyao
cf796a45c1
fix issue
2024-08-15 17:03:32 +08:00
54liuyao
5c859554d0
Merge branch '3.0' of github.com:taosdata/TDengine into fix/TD-31288
2024-08-08 10:36:09 +08:00
54liuyao
8ab78009a9
fix issue
2024-08-07 16:59:19 +08:00
54liuyao
db0c2e4be4
free operator
2024-08-07 15:53:23 +08:00
54liuyao
372c0f21f2
fix mem leak
2024-08-06 19:36:39 +08:00
54liuyao
57068232ff
fix res issue
2024-08-05 16:09:01 +08:00
54liuyao
2b70c1332b
Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-31220
2024-08-05 13:38:10 +08:00
54liuyao
f0e4d2f085
fix malloc issue
2024-08-05 12:22:25 +08:00
Haojun Liao
40537001a2
fix(stream): check return value.
2024-08-05 11:57:18 +08:00
Haojun Liao
3073d6d067
other: merge 3.0
2024-07-27 00:03:28 +08:00
54liuyao
efa65256da
adj operator result
2024-07-25 19:11:32 +08:00
Haojun Liao
b228151d8e
other: merge 3.0
2024-07-24 17:29:35 +08:00
Haojun Liao
aacf1c3e9a
fix(stream): check return value.
2024-07-24 17:08:08 +08:00
54liuyao
5a34a1142f
adj operator result
2024-07-24 16:17:28 +08:00
54liuyao
432731b776
fix ci issue
2024-07-23 14:19:04 +08:00
54liuyao
1d35ea137a
adj query operator result
2024-07-23 10:50:16 +08:00
54liuyao
6e70da62fb
adj operator res
2024-07-22 12:51:25 +08:00
sima
f17c535ca0
feat:[TD-30819] Reduce memory usage when using percentile with interval.
2024-07-10 19:43:19 +08:00
factosea
d9043d6984
fix: unexpected udf function
2024-06-13 16:57:49 +08:00
wangjiaming0909
9ae476c147
fix event window operator forget filting having clause
2024-05-20 10:30:51 +08:00
54liuyao
d63448be72
reset group id for event window
2024-02-04 15:44:49 +08:00
dapan1121
0b18689fa6
fix: fix coverity issues
2023-09-06 10:57:49 +08:00
dapan1121
cc17848b78
fix: merge 3.0 to main
2023-09-01 13:24:47 +08:00
dapan1121
1ca24fea6b
Merge pull request #21742 from wangjiaming0909/feature/3.0/TD-24656
...
feature: add input, output ts order for execution plans
2023-06-18 19:24:29 +08:00
wangjiaming0909
61309862c2
fix comments of TD-24656
2023-06-16 18:12:02 +08:00
wangjiaming0909
fb4f174fbc
feature: add input, output ts order for execution plans
2023-06-16 10:26:09 +08:00
slzhou
e2ac3d00ad
fix: fix mem leak
2023-06-06 10:20:52 +08:00
Haojun Liao
0966213847
fix(arch): set the correct module api dependency.
2023-05-25 14:21:40 +08:00
Haojun Liao
da0d9c78ef
refactor: do some internal refactor.
2023-04-28 11:42:34 +08:00
Haojun Liao
7adc21028a
refactor: do some internal refactor.
2023-04-28 00:23:38 +08:00
Xiaoyu Wang
cf9c2a112f
fix: the number of output lines is incorrect when the event window is used with the multiline function
2023-03-03 15:20:07 +08:00
Haojun Liao
f26fa32340
other: add some comments.
2023-02-13 13:32:01 +08:00
Haojun Liao
c96362d5fc
other: merge event branch.
2023-02-13 13:28:16 +08:00
Haojun Liao
6a6c649113
fix(query): identify the data blocks from different group.
2023-02-13 13:24:59 +08:00
Xiaoyu Wang
0b1bb7a1fb
merge 3.0
2023-01-16 17:55:35 +08:00
Haojun Liao
7efdc9e27a
fix(query): fix memory leak.
2023-01-11 18:00:36 +08:00
Haojun Liao
67a291955e
fix(query): initialize output buffer for each output.
2023-01-11 17:36:01 +08:00
Haojun Liao
169a6703d1
enh(query): support event window.
2023-01-03 17:51:50 +08:00
Haojun Liao
53c3cbd661
enh(query): support event window.
2023-01-03 17:41:10 +08:00