11600 commits

Author	SHA1	Message	Date
Haojun Liao	f9113ab7b0	fix(stream): fix invalid param.	2023-10-09 20:09:11 +08:00
Haojun Liao	b0a4ed3217	fix(stream): drop related fill-history task when dropping stream tasks.	2023-10-09 20:09:10 +08:00
Haojun Liao	83f84d92bc	refactor: do some internal refactor (discard the checkpoint source msg during restoring).	2023-10-09 20:09:10 +08:00
Haojun Liao	bb4ba54f28	fix(stream): enable new time range for stream task.	2023-10-09 20:09:09 +08:00
Haojun Liao	6fbcf4b3d7	fix(tsdb): replace destroy with reset.	2023-10-09 20:09:09 +08:00
Haojun Liao	c759d90bf6	enh(stream): optimize the stream status when creating without fill-history option.	2023-10-09 20:09:09 +08:00
Haojun Liao	db897fb03a	fix(stream): opt perf.	2023-10-09 20:09:09 +08:00
Haojun Liao	dfe8641c0c	refactor: optimize the fill-history task launch policy, and do some other internal refactor.	2023-10-09 20:08:52 +08:00
Haojun Liao	a248f3d088	refactor: do some internal refactor.	2023-10-09 20:08:12 +08:00
Haojun Liao	0db357401d	fix(stream): add new status for meta.	2023-10-09 20:08:12 +08:00
Haojun Liao	3912d80c02	fix(stream): do some internal refactor.	2023-10-09 20:08:11 +08:00
Haojun Liao	feb09c8361	fix(stream): fix error in pause scan-history data.	2023-10-09 20:08:11 +08:00
Haojun Liao	6a98b11bef	fix(stream): fix invalid read and memory leak.	2023-10-09 20:08:11 +08:00
Haojun Liao	65f66f0986	fix(stream): transfer state when all downstream rsp already.	2023-10-09 20:08:11 +08:00
Haojun Liao	4af7812f0b	fix(stream): fix the invalid counter for ready tasks in vnode, fix an invalid read.	2023-10-09 20:08:10 +08:00
Haojun Liao	4fe1382cd9	fix(stream): adjust nodeUpdate check interval.	2023-10-09 20:08:09 +08:00
Haojun Liao	f4f55fcbce	fix(stream): record the tasks started info, and do some internal refactor.	2023-10-09 20:08:09 +08:00
Haojun Liao	68b003c804	fix(stream): fix race condition.	2023-10-09 20:08:09 +08:00
Haojun Liao	52763ca2a3	refactor: do some internal refactor.	2023-10-09 20:08:07 +08:00
Haojun Liao	012ddadf25	fix(stream): update logs.	2023-10-09 20:08:07 +08:00
Haojun Liao	c05a8de3e8	fix(stream): rsp when checkpoint source failed.	2023-10-09 20:08:06 +08:00
Haojun Liao	b4bc4fac98	fix(stream): disable auto rsp for checkpoint source.	2023-10-09 20:08:06 +08:00
Haojun Liao	e671e87234	fix(stream): fix invalid assert.	2023-10-09 20:08:06 +08:00
Haojun Liao	d1a6b8bd22	refactor: do some internal refactor.	2023-10-09 20:08:06 +08:00
Haojun Liao	46b17aa9f1	fix(stream): fix race condition.	2023-10-09 20:08:06 +08:00
Haojun Liao	5eee76df65	fix(stream): add msg identifier check.	2023-10-09 20:08:05 +08:00
Haojun Liao	2b16976902	refactor(stream): refactor send msg.	2023-10-09 20:08:03 +08:00
Haojun Liao	498519c94d	fix(stream): remove invalid node.	2023-10-09 20:08:02 +08:00
Haojun Liao	27e00b1f19	fix(stream): add some logs, and remove invalid assert.	2023-10-09 20:08:02 +08:00
Haojun Liao	124e1ed1ab	enh(stream): add stage info for streamt tasks.	2023-10-09 20:08:02 +08:00
Haojun Liao	12687eb287	fix(stream): add check info detailed information.	2023-10-09 20:08:02 +08:00
Haojun Liao	ab7c18f604	refactor: do some internal refactor.	2023-10-09 20:08:01 +08:00
Haojun Liao	e5535fa1f5	fix(stream): handle dispatch checkpoint-trigger failure.	2023-10-09 20:08:01 +08:00
Haojun Liao	7f4d9b6e41	fix(stream): wait for the task checkpoint before stop.	2023-10-09 20:07:53 +08:00
Haojun Liao	04405b84c5	fix(stream): update logs.	2023-10-09 20:07:53 +08:00
Haojun Liao	118e078f4a	log(stream): update log.	2023-10-09 20:07:53 +08:00
Haojun Liao	ef9efc8a8e	refactor: do refactor the sink task.	2023-10-09 20:07:53 +08:00
Haojun Liao	a3d13d6634	fix(stream): remove invalid cached task info in buffer.	2023-10-09 20:07:08 +08:00
Haojun Liao	1f45bd82d2	other: merge stream fix in main.	2023-10-09 20:07:01 +08:00
Haojun Liao	02610f5546	fix(stream): avoid invalid read.	2023-10-09 20:06:11 +08:00
Haojun Liao	f5da458c77	fix(stream): unlock when returning.	2023-10-09 20:06:11 +08:00
Haojun Liao	36dcdad1a5	fix(stream): return if failed.	2023-10-09 20:06:10 +08:00
Haojun Liao	d76e3ac718	fix(stream): add task status check.	2023-10-09 20:06:10 +08:00
Haojun Liao	29e1efb757	fix(stream): fix obj.	2023-10-09 20:06:10 +08:00
Haojun Liao	a997fa5552	fix(stream): fix deadlock caused by streamTaskHalt function.	2023-10-09 20:06:09 +08:00
Haojun Liao	dff4bd3c8d	log(tsdb): remove some logs.	2023-10-09 20:06:09 +08:00
Haojun Liao	53237c34d1	enh(stream): add info in log.	2023-10-09 20:06:09 +08:00
Haojun Liao	8af76d28c8	log(stream): remove logs.	2023-10-09 20:06:09 +08:00
Haojun Liao	e27111ecd1	enh(stream): add node stage check.	2023-10-09 20:06:09 +08:00
Haojun Liao	927f2d896c	fix(stream): limit the max scan times.	2023-10-09 20:06:08 +08:00