AsyncCollector Does not release the thread (1.2.1)

Hi guys, AsyncCollector.collect(Throwable) method seem to not release the Thread. This scenario may be problematic when calling an external API In the case of a timeout error there is no data to collect. for example : CompletableFuture.supplyAsync(() -> asyncCallTask(input)) .th

Re: AsyncCollector Does not release the thread (1.2.1)

Hi, As far as I know calling collect(Throwable) should also finish the promise that would otherwise fulfilled by successfully collecting a result. If not then you might have found a bug. What makes you think that the Thread is not being released? Is your queue being filled up and no more elemen

Re: AsyncCollector Does not release the thread (1.2.1)

Hi Aljoscha , thank you for your reply, yes the queue being filled up and no more elements are being processed.(In relation to the limit defined at the "orderedWait" function call). To add additional information, if I run the test on a local cluster I can see that the job never ends because the A

Re: AsyncCollector Does not release the thread (1.2.1)

Ok, thanks for letting us know. I’ll investigate. > On 6. Jun 2017, at 19:28, Steve Robert wrote: > > Hi Aljoscha , > > thank you for your reply, > yes the queue being filled up and no more elements are being processed.(In > relation to the limit defined at the "orderedWait" function call). >

Re: AsyncCollector Does not release the thread (1.2.1)

Hi Steve, I’m assuming you are using Flink 1.2.x? If yes, then I’m afraid you re-discovered this issue: https://issues.apache.org/jira/browse/FLINK-6435 . It was fixed in Flink 1.3.0. Is it possible for you to update to that version or do you th