Details
-
Task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
Please see this comment on the PR:
https://github.com/trinodb/trino/pull/10228#issuecomment-1087291399
Currently, while getting next bactch of splits, the split loader is idle until there is something in split queue (class HudiSplitSource). As suggested in the PR comment, we can avoid this blocking implementation and instead use an async queue and return uncompleted future.