Hello Community, I need to have a custom parallel data source (Flink ParallelSourceFunction) for fetching data based on some custom logic. In this source function, opening multiple threads via java thread pool to distribute work further.
These threads share Flink provided 'SourceContext' and collect records via source_context.collect() method. Is it ok to share source context in separate threads and get data? Is there any issue for downstream operators due to above design? Rgds, Kamal
