9693 commits

Author	SHA1	Message	Date
Haojun Liao	b9bda9b30f	fix(stream): set the correct start offset for resumed stream task.	2023-05-17 19:36:42 +08:00
Haojun Liao	73b1a4bddf	fix(stream): fix syntax error.	2023-05-17 18:29:52 +08:00
Haojun Liao	92feb89a09	refactor: do some internal refactor.	2023-05-17 18:08:04 +08:00
Haojun Liao	ffee5ebc61	Merge branch '3.0' into feature/3_liaohj	2023-05-17 17:47:44 +08:00
Haojun Liao	a4d9210b07	fix(tmq): add filter for taosX poll rsp.	2023-05-17 16:40:44 +08:00
Haojun Liao	041ffa91bd	other: merge main.	2023-05-17 15:42:15 +08:00
Haojun Liao	f55f8d245c	fix(tmq): avoid the offset is revised by pool rsp which is issued before invoking tmq_offset_seek function.	2023-05-17 15:19:51 +08:00
Haojun Liao	366cd1871a	Merge pull request #21314 from taosdata/fix/liaohj_main ... fix(stream):extract delete msg from wal.	2023-05-17 14:52:49 +08:00
Haojun Liao	3896e148fd	log(tmq): add some logs.	2023-05-17 11:37:38 +08:00
dapan1121	fb7a06e06e	Merge pull request #21271 from taosdata/enh/tsbsPerf.4 ... Enh/tsbs perf.4	2023-05-17 11:00:14 +08:00
Haojun Liao	f3f52c0232	fix(stream): add some logs and set the wal offset to be the ended version when finishing the step2 recover stage.	2023-05-17 10:43:23 +08:00
Haojun Liao	d457b84aba	Merge pull request #21311 from taosdata/mark/tmq ... fix:add lock to pHandle for safety	2023-05-17 09:11:39 +08:00
wangmm0220	90099ea1c0	fix:compile error in windows	2023-05-16 18:41:35 +08:00
wangmm0220	e6860cada8	fix:compile error in windows	2023-05-16 18:35:10 +08:00
wangmm0220	a52939127f	fix:dead lock	2023-05-16 17:58:31 +08:00
dapan1121	0eb94d97d3	Merge pull request #21320 from taosdata/fix/TD-24167 ... pause source task	2023-05-16 15:39:59 +08:00
dapan1121	9033d34852	Merge pull request #21319 from taosdata/fix/TD-24178 ... fix: file fd not clear issue	2023-05-16 14:34:05 +08:00
dapan1121	e7df9b8fa0	enh: optimize copy group result	2023-05-16 14:12:48 +08:00
wangmm0220	e6e0ac7603	fix:alwalys in exec if consumer Id mismatch & check result for wal seek ver	2023-05-16 14:01:38 +08:00
Haojun Liao	e35d145734	fix(stream): fix memory leak.	2023-05-16 13:59:13 +08:00
liuyao	3c81137ffe	pause source task	2023-05-16 13:43:46 +08:00
Hui Li	ea50ba248e	Merge pull request #21309 from taosdata/FIX/TD-24069-main ... fix: ignore crash signals in dmLogCrash	2023-05-16 11:04:21 +08:00
dapan1121	dc67223deb	fix: file fd not clear issue	2023-05-16 10:47:49 +08:00
Haojun Liao	30e7cb5860	fix(tmq): avoid return delete msg for table subscription.	2023-05-16 10:42:02 +08:00
Haojun Liao	d1a746e4e7	Merge pull request #21295 from taosdata/enh/rocksdbSstateMerge ... Enh/rocksdb sstate merge	2023-05-16 10:15:45 +08:00
Haojun Liao	5e16db4e19	fix(stream):extract delete msg from wal.	2023-05-16 08:54:03 +08:00
wangmm0220	62520af2e5	fix:core dump	2023-05-16 00:32:21 +08:00
Benguang Zhao	b479d510da	fix: ignore crash signals in dmLogCrash	2023-05-15 19:39:03 +08:00
Haojun Liao	d585f34ea9	fix(tmq): avoid seek to previous position.	2023-05-15 18:48:50 +08:00
wangmm0220	36454c73ed	fix:add lock to pHandle for safety	2023-05-15 18:38:14 +08:00
dapan1121	143d3b2ee9	Merge pull request #21291 from taosdata/feat/TD-24115-3.0D ... feat: create dnode limited by grant of cpu cores	2023-05-15 18:01:03 +08:00
Haojun Liao	9feb0a86d6	fix(tmq): assert after the assignment of value.	2023-05-15 12:46:00 +08:00
Haojun Liao	6aa197123e	refactor: do some internal refactor.	2023-05-15 11:29:23 +08:00
Haojun Liao	6f7add8870	refactor: do some internal refactor.	2023-05-15 10:48:03 +08:00
Haojun Liao	6cbedc5d4a	refactor: do some internal refactor.	2023-05-15 10:45:01 +08:00
yihaoDeng	9c0d2c87c6	Merge branch 'enh/3.0' into enh/rocksdbSstateMerge	2023-05-15 01:52:42 +00:00
Haojun Liao	170c603995	other: merge 3.0	2023-05-13 20:16:55 +08:00
kailixu	2b9f9add3a	feat: create dnode limited by grant of cpu cores	2023-05-13 20:10:02 +08:00
Haojun Liao	99148d6719	other: merge 3.0	2023-05-13 20:02:48 +08:00
Haojun Liao	236926b9ee	other: merge enh/rocksdbstate	2023-05-13 19:49:28 +08:00
Haojun Liao	1975e94501	Merge branch 'main' into enh/rocksdbSstate	2023-05-13 19:41:03 +08:00
Haojun Liao	40ffe0cd83	fix(tmq): check handle status before close sub.	2023-05-13 16:45:21 +08:00
Haojun Liao	b383651d8b	fix(tmq): fix the invalid write and set the flag when closing taosx sub.	2023-05-13 16:17:26 +08:00
Haojun Liao	5b2ef2a675	other: merge main and remove invalid return data for poll.	2023-05-13 02:31:39 +08:00
dapan1121	3ca5559b37	fix: invalid read issue	2023-05-12 19:27:11 +08:00
Haojun Liao	181f9063e9	other: merge 3.0	2023-05-12 18:13:28 +08:00
dapan1121	1a52b3d519	fix: taosd crash issue	2023-05-12 18:13:16 +08:00
wade zhang	f1ca28df09	Merge pull request #21274 from taosdata/fix/invalid-message ... invalid message	2023-05-12 17:25:28 +08:00
Shuduo Sang	fac7381ec3	fix: error wording about reconfig (#21049)	2023-05-12 16:20:52 +08:00
Haojun Liao	99422c87c3	fix(tq): set the offset to be the consume offset, instead of the committed offset. And update the table sim.	2023-05-12 16:14:56 +08:00