Haojun Liao
|
e34deca2ba
|
Merge pull request #23827 from taosdata/fix/changeDebugLog
change debug info
|
2023-11-29 19:48:46 +08:00 |
|
Haojun Liao
|
8b406c0a19
|
Merge pull request #23830 from taosdata/fix/liaohj
fix(stream): fix invalid free.
|
2023-11-28 09:52:28 +08:00 |
Haojun Liao
|
b419650116
|
refactor: do some internal refactor.
|
2023-11-27 18:51:30 +08:00 |
|
Haojun Liao
|
91eea02258
|
fix(stream): fix invalid free.
|
2023-11-27 18:49:22 +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 |
|
Haojun Liao
|
372ac4ebce
|
Merge pull request #23800 from taosdata/fix/TS-4242
fix:[TS-4242] tmq status is always RECOVER
|
2023-11-24 09:25:36 +08:00 |
wangmm0220
|
6a6930cb31
|
fix:[TS-4242] tmq status is always RECOVER
|
2023-11-23 16:25:11 +08:00 |
|
yihaoDeng
|
b6a7c19f5e
|
change http timeout
|
2023-11-23 15:51:22 +08:00 |
|
Haojun Liao
|
0654b9299a
|
fix(stream): fix memory leak.
|
2023-11-23 11:44:25 +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
|
ff9c0c0df4
|
fix(stream): fix error in check trans conflict.
|
2023-11-23 09:38:11 +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
|
6fca8c170c
|
enh(stream): add sink_quota/scan-history-idle-duration column for stream tasks.
|
2023-11-23 09:33:44 +08:00 |
|
Haojun Liao
|
8204db13aa
|
enh(stream): add sink_quota column for stream tasks.
|
2023-11-23 09:33:42 +08:00 |
|
Haojun Liao
|
b7347a1d64
|
fix(stream): remove invalid assert
|
2023-11-23 09:33:41 +08:00 |
|
Haojun Liao
|
3edb25a49e
|
fix(stream): add check for assert.
|
2023-11-23 09:33:40 +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
|
41aa175099
|
fix(stream): add return.
|
2023-11-23 09:33:36 +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 |
wade zhang
|
a74063fe9b
|
Merge pull request #23754 from taosdata/fix/TD-27416-main
TD-27416
|
2023-11-21 12:00:32 +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 |
dmchen
|
376f78788e
|
TD-27416
|
2023-11-20 08:43:12 +00: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
|
56edf1b52c
|
enh(stream): add sink_quota 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
|
0fac706fa6
|
Merge pull request #23732 from taosdata/fix/pause_stream
fix(stream): add check for assert.
|
2023-11-17 11:33:19 +08:00 |
|
wade zhang
|
440a750d64
|
Merge pull request #23711 from taosdata/fix/TD-27336-main
fix/TD-27336
|
2023-11-17 09:00:06 +08:00 |
|
Haojun Liao
|
c070e79d36
|
fix(stream): add check for assert.
|
2023-11-16 23:18:07 +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 |
|
dmchen
|
1e2c9b03a1
|
copy sql before destroy
|
2023-11-16 02:22:01 +00:00 |
|
dm chen
|
b18aa087da
|
Revert "create steam"
This reverts commit cd6df48df5.
|
2023-11-16 10:09:46 +08:00 |
|
dmchen
|
cd6df48df5
|
create steam
|
2023-11-16 01:49:31 +00:00 |
dapan1121
|
dc71252096
|
Merge remote-tracking branch 'origin/3.0' into merge/32m
|
2023-11-15 19:43:19 +08:00 |
|
wade zhang
|
a405a981be
|
Merge pull request #23500 from taosdata/fix/transaction-retry-main
fix/transaction-retry
|
2023-11-15 19:19:02 +08:00 |
|
wade zhang
|
297fea94df
|
Merge pull request #23700 from taosdata/FIX/transaction-retry-3.0
Fix/transaction retry 3.0
|
2023-11-15 19:18:41 +08:00 |
|
dmchen
|
82498a9b4e
|
create stream
|
2023-11-15 10:44:53 +00:00 |
|
dmchen
|
51abd736e0
|
fix/TD-27336
|
2023-11-15 10:13:00 +00:00 |