Pan Wei
|
fceced930a
|
fix: exchange param issue (#31814)
* 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
---------
Co-authored-by: huohong <sallyhuo@taosdata.com>
|
2025-07-11 18:24:16 +08:00 |
|
Pan Wei
|
5df70fead0
|
fix: memory issues (#31716)
* 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
---------
Co-authored-by: huohong <sallyhuo@taosdata.com>
|
2025-07-08 19:20:10 +08:00 |
|
dapan1121
|
788a5d603f
|
fix: return code issue
|
2025-07-08 10:24:27 +08:00 |
|
Pan Wei
|
e3b186eeff
|
fix: memory issues (#31671)
* 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
---------
Co-authored-by: huohong <sallyhuo@taosdata.com>
|
2025-07-05 18:15:00 +08:00 |
|
dapan1121
|
e6645c2e74
|
fix: crash issue
|
2025-06-27 07:58:46 +08:00 |
|
facetosea
|
e518cfeaa8
|
fix: decimal type
|
2025-06-24 20:09:17 +08:00 |
|
dapan1121
|
b0bb2a715d
|
enh: add recalc systable
|
2025-06-24 18:06:20 +08:00 |
|
dapan1121
|
27d51d5d4b
|
enh: add recalc stream
|
2025-06-24 13:21:01 +08:00 |
|
dapan1121
|
44838002dd
|
fix: recalc stream
|
2025-06-21 18:50:48 +08:00 |
|
dapan1121
|
781d0bf9a3
|
enh: add stream and tasks info
|
2025-06-17 16:55:32 +08:00 |
|
dapan1121
|
1de92ec843
|
fix: catalog crash issue
|
2025-06-16 15:19:05 +08:00 |
|
wangmm0220
|
867625ff4b
|
fix(stream): add logic of %%tbname & checkpoint
|
2025-06-06 19:43:44 +08:00 |
|
Jing Sima
|
53e13c9b48
|
feat: [TS-6100] Parse create stream sql: Fix vgroups
|
2025-06-06 17:06:06 +08:00 |
|
dapan1121
|
33ca255671
|
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9
|
2025-06-06 09:15:50 +08:00 |
|
dapan1121
|
bfce943ff0
|
enh: add more check
|
2025-06-06 09:09:40 +08:00 |
|
facetosea
|
176913fbbd
|
feat: show streams
|
2025-06-05 11:33:22 +08:00 |
|
dapan1121
|
c27ad1ab64
|
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw9
|
2025-05-30 09:02:01 +08:00 |
|
dapan1121
|
b3b8db8307
|
enh: enhance stream mgmt
|
2025-05-30 08:56:34 +08:00 |
|
dapan1121
|
621edcdd02
|
fix: add status
|
2025-05-28 18:37:21 +08:00 |
|
dapan1121
|
829921cc21
|
fix: start/stop stream
|
2025-05-28 17:27:53 +08:00 |
|
dapan1121
|
ca895c39aa
|
fix: start/stop stream
|
2025-05-28 17:17:54 +08:00 |
|
dapan1121
|
01d2677fca
|
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw8
|
2025-05-27 19:12:25 +08:00 |
|
dapan1121
|
f7c1fddf9a
|
fix: add watch processing
|
2025-05-27 19:08:07 +08:00 |
|
Jinqing Kuang
|
18566df281
|
Merge branch '3.0' into kjq-merge
|
2025-05-24 14:56:21 +08:00 |
|
dapan1121
|
270e383229
|
enh: add mnode error handling
|
2025-05-23 18:14:34 +08:00 |
|
dapan1121
|
e4cd39affc
|
fix: add stream object debug log
|
2025-05-19 17:46:59 +08:00 |
|
dapan1121
|
097a9ba275
|
fix: drop snode task list issue
|
2025-05-19 09:54:46 +08:00 |
|
dapan1121
|
85767a9cbf
|
enh: enhance drop snode
|
2025-05-17 16:36:35 +08:00 |
|
dapan1121
|
66ab04dc49
|
enh: add stream and snode assignment
|
2025-05-17 10:55:32 +08:00 |
|
Haojun Liao
|
d02b17be0e
|
fix(stream): extends the node update check interval. (#31048)
|
2025-05-14 10:15:17 +08:00 |
|
Jing Sima
|
0c490df458
|
feat: [TS-6100] Parse create stream sql: Fix partition by tbname error.
|
2025-05-13 14:13:20 +08:00 |
|
dapan1121
|
ca2241f6ad
|
fix: add snode task redeploy
|
2025-05-10 17:16:39 +08:00 |
|
dapan1121
|
ee09c9643c
|
Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw5
|
2025-05-09 11:32:10 +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
|
2d499c9572
|
fix: stream queue issue
|
2025-04-29 15:32:56 +08:00 |
|
dapan1121
|
ef1e51e9b9
|
enh: add stream obj name
|
2025-04-29 08:38:03 +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
|
ae0e1ded7d
|
enh: add hb processing
|
2025-04-22 17:46:17 +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
|
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 |
|
Haojun Liao
|
af06bea439
|
fix(stream): add start/stop message. (#30400)
|
2025-03-24 19:38:00 +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 |
|
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 |
|