3a739beaa5
Merge branch 'main' into merge/mainto3.0
2025-02-22 20:07:40 +08:00
2228a9fc33
Merge branch 'main' into fix/checkfh
2025-02-21 11:11:36 +08:00
24cce3477f
fix(stream): update the checkpoint info for follower anyway.
2025-02-21 10:00:55 +08:00
ecc667c22b
Revert "refactor(stream): drop task in async ways"
2025-02-21 01:10:18 +08:00
306f6ebc93
fix(stream): clear start task info if no tasks exist.
2025-02-20 23:54:06 +08:00
2bee60a41a
Merge branch 'main' into merge/mainto3.0
2025-02-20 18:12:02 +08:00
42bafc0d47
Merge pull request #29848 from taosdata/fix/ly_stream
...
fix(tsma):drop invalid state for tsma
2025-02-20 15:04:03 +08:00
0a9f5086f0
Merge pull request #29775 from taosdata/fix/analysis
...
refactor(stream): drop task in async ways
2025-02-20 13:38:53 +08:00
870fe1c071
fix(tsma):drop invalid state for tsma
2025-02-20 11:52:04 +08:00
f16ae7abe1
Merge pull request #29809 from taosdata/merge/mainto3.0
...
merge: from main to 3.0 branch
2025-02-20 10:27:20 +08:00
92eb6038e2
Merge pull request #29762 from taosdata/feat/TS-5469-3.0
...
feat(stream)[TS-5469]: add more stream event notifications
2025-02-18 15:14:58 +08:00
63fc5dea34
Merge branch '3.0' into merge/mainto3.0
2025-02-18 10:29:16 +08:00
c4cd6dd62d
fix(stream): drop task in synch model in write thread.
2025-02-17 10:06:09 +08:00
596e381e0e
Merge pull request #29779 from taosdata/fix/metanull
...
fix(stream): access value after null ptr check.
2025-02-17 09:36:09 +08:00
fc2d2672b9
feat(stream)[TS-5469]: add more stream event notifications
...
- Add event notifications for all window types
- Implement window invalidation notifications
- Add statistics for event notification delivery
2025-02-16 11:07:16 +08:00
465e5eabd7
fix(stream): drop task in synch model in write thread.
2025-02-15 23:20:05 +08:00
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
73ec4af4a7
Merge branch 'main' into fix/analysis
2025-02-14 15:37:11 +08:00
89d5444ed1
fix(stream): access value after null ptr check.
2025-02-14 14:46:19 +08:00
297f248203
fix(stream): access value after null ptr check.
2025-02-14 14:34:08 +08:00
fd96b096ea
refactor(stream): drop task in async ways
2025-02-13 23:41:06 +08:00
d4b19169ea
fix(stream): fix double free when failed to send msg.
2025-02-12 15:33:50 +08:00
78e976caff
refactor(stream): limit stream input q size.
2025-02-11 22:57:28 +08:00
9d0a4f88f3
refactor(stream): idle for 1s when exec for 5s.
2025-02-11 22:57:23 +08:00
cd52401303
Merge branch 'main' into merge/mainto3.02
2025-02-11 15:15:35 +08:00
a2dcba10a7
refactor(stream): 1) notify closing in main thread. 2) not saving the halt status.
2025-02-09 01:42:24 +08:00
a004d95996
Merge branch '3.0' into merge/mainto3.02
2025-02-06 13:46:36 +08:00
093233203d
Revert "refactor(stream): do some internal refactor ."
2025-01-24 17:11:15 +08:00
3089e3d904
Merge pull request #29544 from taosdata/fix/tag
...
refactor(stream): do some internal refactor .
2025-01-24 16:27:22 +08:00
8c0600649f
Merge pull request #29623 from taosdata/merge/mainto3.0
...
merge: from main to 3.0 branch
2025-01-22 16:36:17 +08:00
eb5d463490
feat(stream)[TS-5469]. add support for window event notifications in stream processing
...
- Introduce new syntax to specify notification type and destination address
- Collect relevant event information during window computations
- Implement websocket-based notification delivery to the specified address
2025-01-21 17:39:46 +08:00
3206c688ed
fix(stream): fix syntax error.
2025-01-21 16:30:43 +08:00
0ea46585f4
fix(stream): update checkpoint-info after check the failed checkpointId, and update the consensus-checkpoint id in mnode.
2025-01-21 16:29:00 +08:00
c93fe999ba
refactor(stream): injection error.
2025-01-18 01:26:49 +08:00
6274eea7c4
fix(stream): adjust the free stream meta position and check the close flag of streamMeta before starting scan wal.
2025-01-17 19:15:08 +08:00
29421c17d8
fix(stream): fix syntax error.
2025-01-16 17:48:26 +08:00
eff1aff58e
fix(stream): update the task last msgId when putting into input queue succ.
2025-01-16 17:16:31 +08:00
a3eea6fe1c
fix(stream): fix race condition.
2025-01-10 14:11:15 +08:00
737138856c
refactor(stream): track the msgId for each upstream tasks.
2025-01-10 11:29:17 +08:00
d344228242
enh(stream): reduce the in-queue size to be 10MiB.
2025-01-08 19:11:41 +08:00
c372b5da51
fix invalid lock
2025-01-03 16:09:32 +08:00
94ea52ad9d
Merge pull request #29404 from taosdata/fix/tag
...
fix(stream): replace functions with safty ones.
2024-12-31 15:49:06 +08:00
1d0ab80e75
fix(stream): check return value for snprintf
2024-12-31 11:59:13 +08:00
5a1e5b1549
fix(stream): check return value for snprintf
2024-12-31 11:52:06 +08:00
44cfecc402
refactor: remove unused codes.
2024-12-30 13:41:34 +08:00
8c7ee17dd1
fix(stream): replace functions with safty ones.
2024-12-30 13:36:57 +08:00
0c8ac0f2ec
enh(stream): inc the timeout threshold to be 600s.
2024-12-29 00:42:39 +08:00
ba4d47b8b6
enh(stream): extend wait time upto 300s
2024-12-29 00:15:58 +08:00
912fcb13bf
Merge pull request #29351 from taosdata/merge/mainto3.0
...
merge: from main to 3.0 branch
2024-12-27 09:06:35 +08:00
030bcbf487
Merge pull request #29340 from taosdata/fix/liaohj
...
fix(stream): log error and continue running
2024-12-26 14:41:32 +08:00
Shengliang Guan
Haojun Liao
Haojun Liao
54liuyao
Jinqing Kuang
yihaoDeng