Jinqing Kuang
6921e31b62
fix(stream): fix notification for stream with project operator ( #30879 )
2025-04-25 17:24:15 +08:00
WANG MINGMING
ca724865b9
fix(stream): parName is null ( #30592 )
2025-04-19 10:26:32 +08:00
liuyao
fac36002c1
ci(stream): add ci and fix issue ( #30270 )
...
* ci(stream): add ci and fix issue
* ci: adj test
* ci: add test and fix issue
* ci: adj test
* ci(stream): add test for fill operator and fix issue
* fix: fix issue
* fix: fix issue
* fix: adjust defalut rec value
2025-03-20 10:34:31 +08:00
liuyao
2de6736160
feat(stream): add new trigger continuous_window_close ( #30125 )
...
* opt stream build twa result
* opt force window close memory
* feat(stream):optimize new interval and scan operator
* adj log
* opt code
* opt code
* fill history
* fix issue for fill history
* add ci
* feat(stream): add new stream nonblock interval operator
* adjust code
* use new scan operator
* use new scan operator
* add log
* fix issue
* recover stream scan next function
* fix issue
* fix issue
* fix issue
* ignore disorder data
* fix issue
* fix issue for interval sliding
* fix issue
* fix ci issue
* fix ci issue
* fix ci issue
* add semi && final nonblock interval operator
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* refactor(stream): track the msgId for each upstream tasks.
* fix(stream): fix race condition.
* fix(stream): update the task last msgId when putting into input queue succ.
* fix issue
* fix issue
* put recalculate data to rocksdb
* fix issue
* fix issue
* enh(query)[TD-33071]: add support for saving and restoring tsdbReader scan progress
- Implement functionality to save scan progress during tsdbReader operations
- Enable resuming scans from the last saved position
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* add rec interval check
* enh(stream):add recalculate tasks.
* enh(stream): support the re-calculate the tasks.
* fix issue && do refactor
* do refactor
* fix issue
* fix issue
* update backend opt
* add new interface
* add new session operator
* support blob
* add new session operator
* fix issue
* add rec state for rec task
* fix invalid read
* add new session window
* enh(stream): update the stream tasks backend.
* new session operator
* add pull data
* fix(stream): fix error in expand stream backend.
* fix issue
* fix issue
* fix issue
* merge code
* fix issue
* fix(stream): check for null ptr.
* fix(stream): add more check.
* fix issue
* fix issue
* fix issue
* add debug code
* fix issue
* fix issue
* fix issue
* set rec end flag
* fix(stream): opt re-calculate stream tasks.
* fix issue
* fix issue
* add new operator
* enh(stream): dispatch recalculate block to agg tasks.
* fix issue
* fix issue
* fix(stream): adjust filter.
* fix issue
* refactor
* refactor(stream): adjust the recalculate end block.
* fix issue
* fix(stream): set correct create trigger block.
* fix issue
* fix(stream): fix error in build recalculate end block.
* fix(stream): check null ptr.
* add stream client && fix issue
* fix mem leak
* fix(stream): free msg.
* add stream client
* fix(stream): fix error.
* add stream client && fix issue
* add stream client
* refactor(stream): set the recalculate task complete.
* add wend and group_id for session window dest table
* feat(stream): refactor and set the recalcul agg task complete.
* add cfg for adapter
* fix issue
* add state && event operator
* feat(stream): support fill-history task.
* add new fill operator
* fix(stream): set correct backend when updating fill-history task to recalculate task.
* add new fill operator
* fix(stream): s2025-03-06 11:10:31.272
et ops always open in scan tsdb
* fix(stream):set the correct taskType for sink task.
* new fill operator
* adj stream fill operator
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* fix issue
* adj test
* fix issue
* fix(stream): fix issue
* fix(steam): fix issue
* fix(steam): fix issue
* fix(steam): fix issue
* fix(steam): fix issue
* fix(stream): fix issue
* fix(stream): fix issue
* fix(stream): fix issue
* fix: ut com error
* fix(stream): fix mem leak and adjust operator type check rule
* fix(stream): fix mem leak and adjust test case
* refactor code
* fix(stream): free items.
* fix(stream): free fix memory leak.
* fix(stream): fix syntax error.
* fix: ignore unexpect block
* fix: adjust op type
---------
Co-authored-by: Haojun Liao <hjliao@taosdata.com>
Co-authored-by: Jinqing Kuang <kuangjinqingcn@gmail.com>
Co-authored-by: yihaoDeng <luomoxyz@126.com>
2025-03-14 20:14:01 +08:00
Haojun Liao
11e7126f98
Merge branch 'main' into enh/killtrans
2025-02-27 00:35:28 +08:00
Haojun Liao
45b0e47a19
refactor(stream): add long exec stream queue for history tasks in step1 and re-calculate task execution.
2025-02-27 00:15:03 +08:00
Jinqing Kuang
a987d925a1
fix(query)[TD-33833]: fix function projectApplyFunctions for null pointer handling
2025-02-25 15:48:25 +08:00
Haojun Liao
ecc667c22b
Revert "refactor(stream): drop task in async ways"
2025-02-21 01:10:18 +08:00
Haojun Liao
25cdfa5ee9
refactor(stream): add long exec stream queue for history tasks in step1 and re-calculate task execution.
2025-02-14 18:34:20 +08:00
factosea
c85a57c055
fix: join cols not set
2025-01-08 11:24:24 +08:00
facetosea
a2f8a822da
remove some check
2024-11-27 19:51:27 +08:00
factosea
22f3c20977
enh: check param
2024-11-25 11:33:02 +08:00
Jinqing Kuang
83f1a590b0
fix(query)[TD-32258]. Fix error handling in operator interface functions
...
- Contain errors within individual operators, preventing error
propagation to upper-level operators
- Use longjmp to jump directly to the outermost error handler
for unresolvable issues, avoiding unnecessary error code
returns through multiple layers
- Simplify error-handling logic for better maintainability
2024-09-24 18:15:14 +08:00
Haojun Liao
0236db51f6
fix(query): fix memory leak and do some internal refactor.
2024-09-06 15:44:25 +08:00
Pan Wei
1e977a324e
Merge pull request #27654 from taosdata/fix/3.0/TD-31818
...
fix:[TD-31818] fix memory leak allocated by mode function.
2024-09-04 09:16:12 +08:00
Jing Sima
02dd9c9160
fix:[TD-31818] fix memory leak allocated by mode function.
2024-09-03 17:34:23 +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
wangjiaming0909
043a8a8cfc
use internal error
2024-08-22 19:15:57 +08:00
wangjiaming0909
e6a35dd34d
remove asserts of nodes/planner/parser/tsdbread
2024-08-22 19:15:18 +08:00
Jing Sima
16d314a6ae
fix:[TD-31588] Handle error when initFunc failed .
2024-08-21 18:50:08 +08:00
54liuyao
a82c220645
fix issue
2024-08-15 17:38:29 +08:00
54liuyao
cf796a45c1
fix issue
2024-08-15 17:03:32 +08:00
54liuyao
fe75c72666
fix issue
2024-08-08 16:24:18 +08:00
54liuyao
db0c2e4be4
free operator
2024-08-07 15:53:23 +08:00
Haojun Liao
9e8038b020
Merge pull request #27022 from taosdata/fix/TD-31270
...
fix mem leak
2024-08-07 09:30:19 +08:00
54liuyao
372c0f21f2
fix mem leak
2024-08-06 19:36:39 +08:00
Haojun Liao
e0fc36ce97
fix(query):check return code
2024-08-06 17:32:20 +08:00
54liuyao
a9f1cff14f
fix issue
2024-08-05 17:08:21 +08:00
Haojun Liao
40537001a2
fix(stream): check return value.
2024-08-05 11:57:18 +08:00
Haojun Liao
75c121c18a
fix(query): check return value.
2024-07-28 14:29:56 +08:00
Haojun Liao
7be2ecbe1f
fix(common): check the return value.
2024-07-27 18:55:34 +08:00
Haojun Liao
8876b2602d
fix(stream): check return value.
2024-07-27 11:02:35 +08:00
Haojun Liao
3dc23b363f
fix(query): set correct error code.
2024-07-25 09:55:27 +08:00
Haojun Liao
d2d7fdfa61
fix(query): ignore one return value.
2024-07-24 18:43:35 +08:00
Haojun Liao
aacf1c3e9a
fix(stream): check return value.
2024-07-24 17:08:08 +08:00
dapan1121
e4c624f286
Merge pull request #26489 from taosdata/fix/3.0/TD-30819
...
feat:[TD-30819] Reduce memory usage when use percentile with interval.
2024-07-11 13:35:39 +08:00
sima
f17c535ca0
feat:[TD-30819] Reduce memory usage when using percentile with interval.
2024-07-10 19:43:19 +08:00
factosea
28dc3c85ea
type overflow
2024-07-08 20:38:23 +08:00
factosea
99f9c28e77
fix: return code
2024-07-05 08:07:00 +08:00
factosea
593d8adc42
test case
2024-07-04 15:56:12 +08:00
factosea
5f0ac46029
diff
2024-07-04 11:04:59 +08:00
dapan1121
e7a43b4e58
fix: projection limit 0 issue
2024-04-16 18:47:03 +08:00
dapan1121
55d118d17c
Merge remote-tracking branch 'origin/3.0' into feat/TD-27337
2024-04-16 09:12:04 +08:00
dapan1121
4217223a6a
fix: join merge block issue
2024-04-03 09:54:49 +08:00
54liuyao
5369448bda
adj log
2024-04-01 16:43:36 +08:00
54liuyao
14c6dbd2af
use non sort merge
2024-03-12 11:45:54 +08:00
shenglian zhou
ca6ed89f6f
fix: return error code instead of just out of memory
2024-02-26 10:24:59 +08:00
shenglian zhou
9c9d9dc24b
fix: add input ignore group
2024-01-16 08:13:47 +08:00
