You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2019/02/28 16:31:30 UTC

[GitHub] azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions
URL: https://github.com/apache/flink/pull/7186#issuecomment-468340433
 
 
   Thanks for working on this @QiLuo-BD @zhijiangW 
   
   I have a question about `CloseRequest` reliability. What if this message does not reach the producer? E.g. dropped by network or consumer fails. It seems to hold the release of `TaskExecutor`. Currently, it seems to lead to resources leak only on the `TaskExecutor` while is still running.
   
   I am mot sure about current yarn deployment but if the `TaskExecutor`'s are not reused there (rather always newly allocated), it will lead to growing number of idle executors in case of abrupt job failures.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services