fix(flow): correctness bugs #16553

Job	Run time
Check License Header	1m 25s
Toml Check	19s
Check typos and docs	9s
Check (windows-2022)	6m 59s
Build GreptimeDB binaries (ubuntu-20.04)	4m 15s
Build GreptimeDB binary (profile-CI) (ubuntu-20.04)	10m 47s
Check (ubuntu-20.04)	8m 47s
Clippy	9m 42s
Rustfmt	32s
coverage	0s
Sqlness Test (ubuntu-20.04)	2m 25s
Unstable Fuzz Test (unstable_fuzz_create_table_standalone)	13m 45s
Fuzz Test (fuzz_create_table)	5m 16s
Fuzz Test (fuzz_alter_table)	4m 43s
Fuzz Test (fuzz_create_database)	4m 48s
Sqlness Test with Kafka Wal (ubuntu-20.04)	3m 6s
Fuzz Test (fuzz_create_logical_table)	5m 6s
Fuzz Test (fuzz_alter_logical_table)	4m 52s
Fuzz Test (fuzz_insert)	4m 57s
Fuzz Test (fuzz_insert_logical_table)	4m 42s
Fuzz Test (Distributed, Disk) (fuzz_create_table)	6m 43s
Fuzz Test (Distributed, Disk) (fuzz_alter_table)	6m 36s
Fuzz Test (Distributed, Disk) (fuzz_create_database)	6m 36s
Fuzz Test (Distributed, Disk) (fuzz_create_logical_table)	7m 4s
Fuzz Test (Distributed, Disk) (fuzz_alter_logical_table)	7m 21s
Fuzz Test (Distributed, Disk) (fuzz_insert)	6m 59s
Fuzz Test (Distributed, Disk) (fuzz_insert_logical_table)	6m 49s
	2h 24m 43s

Provide feedback