Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Direct runner reads 10 records at a time from a reader. I think the intention is to reuse the reader, but it reuses only if the reader is idle initially, not when the source has messages available.
When I was testing KafkaIO with direct runner it kept opening new reader for every 10 records and soon ran out of file descriptors.
Attachments
Issue Links
- links to