Snowflake bounded source + Flink runner fix#38064

Open

turb wants to merge 2 commits intoapache:masterfrom

turb:snowflake-bounded

Commits on Apr 3, 2026

Fix LazyFlinkSourceSplitEnumerator that did not wait that input split are ready before launching subtasks
turb
committed
SnowflakeIO: use BoundedSource to allow parallel reading of partitioned files generated by Snowflake COPY.
turb
committed