flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexander Smirnov <alexander.smirn...@gmail.com>
Subject Multi threaded operators?
Date Mon, 23 Apr 2018 09:54:30 GMT

I have a co-flatmap function which reads data from external DB on specific
The API for the DB layer is homegrown and it uses multiple threads to speed
up reading.

Can it cause any problems if I use the multithreading API in the flatmap1
function? Is it allowed in Flink?

Or, maybe I should employ better approaches for that. May be async I/O?

Thank you,

View raw message