wade zhang
|
0082c071b7
|
Merge pull request #23968 from taosdata/fix/TS-4251-main
fix/TS-4251
|
2023-12-11 11:19:41 +08:00 |
yihaoDeng
|
35e948ecfa
|
refactor code
|
2023-12-06 16:05:44 +08:00 |
|
yihaoDeng
|
5cc67ca9f6
|
refactor code
|
2023-12-06 15:51:05 +08:00 |
dmchen
|
dc9408ed5f
|
fix/TS-4251
|
2023-12-06 07:48:40 +00:00 |
|
yihaoDeng
|
54f8a816b5
|
add http fast quit
|
2023-12-06 14:01:32 +08:00 |
Haojun Liao
|
4d9211dcf1
|
Merge pull request #23899 from taosdata/fix/liaohj
other: merge the patch of stream from 3.0 branch.
|
2023-12-01 15:49:54 +08:00 |
Haojun Liao
|
d7a19a9179
|
fix(stream): fix invalid decode hbmsg and memory leaks caused by invalid hb msg.
|
2023-12-01 14:45:18 +08:00 |
|
Haojun Liao
|
dba58f5e38
|
fix(stream): fix syntax error.
|
2023-12-01 11:54:13 +08:00 |
|
Haojun Liao
|
e753d631af
|
fix(stream): make sure open operator only once for scan-history task.
|
2023-12-01 10:21:07 +08:00 |
|
Haojun Liao
|
1df29b5d6c
|
fix(stream): disable the time slice usage limitation for stream task.
|
2023-12-01 10:20:15 +08:00 |
|
Haojun Liao
|
57b8388dad
|
fix(stream): fix error.
|
2023-12-01 10:20:00 +08:00 |
|
Haojun Liao
|
468094c86a
|
fix(stream):set failure for the related fill-history task.
|
2023-12-01 10:19:45 +08:00 |
|
Haojun Liao
|
9d735e7f8b
|
fix(stream): reduce the sink throughput. and fix the bug in status check.
|
2023-12-01 10:18:25 +08:00 |
|
Haojun Liao
|
2b03d64850
|
fix(stream): drop the related fill-history task & set the task to be ready, if the drop fill-history task msg is missing due to the vnode restarting.
|
2023-12-01 10:18:15 +08:00 |
|
Haojun Liao
|
f54fe2d6ef
|
refactor: do some internal refactor.
|
2023-12-01 10:17:15 +08:00 |
|
Haojun Liao
|
fee9d751d4
|
fix(stream): fix the race condition in dispatching data.
|
2023-12-01 10:17:14 +08:00 |
|
yihaoDeng
|
276619caed
|
change debug info
|
2023-11-27 14:08:44 +08:00 |
|
Haojun Liao
|
d51baab9c2
|
Merge pull request #23785 from taosdata/fix/liaohj
other: merge fix from 3.0 to main.
|
2023-11-24 14:43:02 +08:00 |
|
yihaoDeng
|
b6a7c19f5e
|
change http timeout
|
2023-11-23 15:51:22 +08:00 |
|
Haojun Liao
|
8ad071e69a
|
other: merge main.
|
2023-11-23 10:25:51 +08:00 |
|
Haojun Liao
|
630b259d7f
|
fix(stream): fix error in stream.
|
2023-11-23 09:41:07 +08:00 |
|
Haojun Liao
|
f3355000a3
|
refactor: do some internal refactor.
|
2023-11-23 09:34:20 +08:00 |
|
Haojun Liao
|
00f8103262
|
fix(stream): fix error in generating token in bucket.
|
2023-11-23 09:34:19 +08:00 |
|
Haojun Liao
|
b7347a1d64
|
fix(stream): remove invalid assert
|
2023-11-23 09:33:41 +08:00 |
|
Haojun Liao
|
466c80e370
|
fix(stream): fix bug in delay send.
|
2023-11-23 09:33:38 +08:00 |
|
Haojun Liao
|
957ce07dc4
|
fix(stream): fix syntax error.
|
2023-11-23 09:33:38 +08:00 |
|
Haojun Liao
|
298755cc4e
|
fix(stream): wait for task to be normal and then send data block.
|
2023-11-23 09:33:37 +08:00 |
|
Haojun Liao
|
8c4558c5c2
|
Merge pull request #23763 from taosdata/fix/pause_stream
fix(stream): fix error in generating token in bucket.
|
2023-11-21 15:46:25 +08:00 |
|
Haojun Liao
|
d9844fbf9e
|
Merge pull request #23701 from taosdata/fix/TD-26952
fix mem leak
|
2023-11-21 10:46:56 +08:00 |
|
Haojun Liao
|
1077378d51
|
other: merge main.
|
2023-11-21 10:14:30 +08:00 |
|
Haojun Liao
|
4b3495cd4b
|
refactor: do some internal refactor.
|
2023-11-21 10:11:02 +08:00 |
|
Haojun Liao
|
e78b04be51
|
fix(stream): fix error in generating token in bucket.
|
2023-11-21 10:11:02 +08:00 |
|
Haojun Liao
|
ec919415b8
|
enh(stream): add sink_quota/scan-history-idle-duration column for stream tasks.
|
2023-11-20 12:03:23 +08:00 |
|
Haojun Liao
|
1b4f187ded
|
Merge pull request #23743 from taosdata/fix/pause_stream
fix(stream): remove invalid assert
|
2023-11-17 23:48:47 +08:00 |
|
Haojun Liao
|
709502ba9e
|
fix(stream): record the check downstream failure.
|
2023-11-17 22:05:36 +08:00 |
|
Haojun Liao
|
753716f1e6
|
fix(stream): remove invalid assert
|
2023-11-17 16:36:17 +08:00 |
|
Haojun Liao
|
3100edae5d
|
Merge pull request #23727 from taosdata/fix/pause_stream
fix(stream): wait for task to be normal and then send data block.
|
2023-11-16 19:51:33 +08:00 |
|
Haojun Liao
|
bc779edda9
|
fix(stream): fix bug in delay send.
|
2023-11-16 17:57:13 +08:00 |
|
Haojun Liao
|
f0f4b988a1
|
fix(stream): fix syntax error.
|
2023-11-16 17:57:13 +08:00 |
|
Haojun Liao
|
a69b870260
|
fix(stream): wait for task to be normal and then send data block.
|
2023-11-16 17:57:13 +08:00 |
|
Haojun Liao
|
f7ee65d059
|
fix(stream): fix send msg error.
|
2023-11-15 16:31:07 +08:00 |
|
Haojun Liao
|
d7fb9c5b6e
|
fix(stream): add missing pushed data.
|
2023-11-15 16:10:26 +08:00 |
|
Haojun Liao
|
9d2256ec9c
|
refactor: do some internal refactor.
|
2023-11-15 16:03:23 +08:00 |
|
Haojun Liao
|
d68c685122
|
Merge pull request #23684 from taosdata/fix/ly_test_main
delete mark
|
2023-11-15 14:48:03 +08:00 |
|
Haojun Liao
|
2ca663ce66
|
Merge pull request #23593 from taosdata/feat/TD-21898
stream event window
|
2023-11-15 14:18:07 +08:00 |
dapan1121
|
9457cf0b46
|
Merge pull request #23702 from taosdata/merge/m23
merge: from main to 3.0
|
2023-11-15 13:54:21 +08:00 |
dapan1121
|
dfb3feb5dc
|
Merge remote-tracking branch 'origin/main' into merge/m23
|
2023-11-15 11:39:18 +08:00 |
|
Haojun Liao
|
51897a679f
|
fix(stream): fix invalid read.
|
2023-11-15 11:21:31 +08:00 |
|
Haojun Liao
|
614e7c49dc
|
Merge pull request #23683 from taosdata/fix/ly_test
delete mark
|
2023-11-15 10:27:35 +08:00 |
|
yihaoDeng
|
5fccaf62b5
|
fix mem leak
|
2023-11-15 10:04:29 +08:00 |