pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-654058889
> Thanks for the contribution. Why default value is 10000? Why not keep Int.Max? @JingsongLi Thanks for your reply , The details link https://issues.apache.org/jira/browse/FLINK-17761 . FutureCompletingBlockingQueue is a LinkedBlockingQueue and it is created using the default constructor, so its depth is Integer.MAX_VALUE. So for a FetchTask to be blocked on a put(), it means that the queue is full so it has Integer.MAX_VALUE elements already . Integer.MAX_VALUE is too large . I changed the default value to 10000 with @becketqin agree. At the same time, a construction method with capacity parameter is added. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
