fix(flow): correctness bugs #16564

Job	Run time
Build GreptimeDB binary (profile-CI) (ubuntu-20.04)	2m 29s
Check (windows-2022)	7m 32s
Check typos and docs	5s
Check (ubuntu-20.04)	1m 43s
Build GreptimeDB binaries (ubuntu-20.04)	4m 21s
Clippy	3m 21s
Rustfmt	23s
Check License Header	1m 22s
coverage	0s
Toml Check	36s
Fuzz Test (Distributed, Disk) (fuzz_create_table)	7m 20s
Fuzz Test (Distributed, Disk) (fuzz_alter_table)	7m 10s
Fuzz Test (Distributed, Disk) (fuzz_create_database)	6m 29s
Fuzz Test (Distributed, Disk) (fuzz_create_logical_table)	6m 33s
Fuzz Test (Distributed, Disk) (fuzz_alter_logical_table)	7m 10s
Fuzz Test (Distributed, Disk) (fuzz_insert)	6m 43s
Fuzz Test (Distributed, Disk) (fuzz_insert_logical_table)	6m 43s
Sqlness Test (ubuntu-20.04)	2m 27s
Sqlness Test with Kafka Wal (ubuntu-20.04)	3m 21s
Fuzz Test (fuzz_create_table)	5m 22s
Fuzz Test (fuzz_alter_table)	4m 45s
Unstable Fuzz Test (unstable_fuzz_create_table_standalone)	13m 42s
Fuzz Test (fuzz_create_database)	4m 48s
Fuzz Test (fuzz_create_logical_table)	5m 33s
Fuzz Test (fuzz_alter_logical_table)	5m 59s
Fuzz Test (fuzz_insert)	5m 24s
Fuzz Test (fuzz_insert_logical_table)	5m 30s
	2h 6m 51s

Provide feedback