You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by zhijiangW <gi...@git.apache.org> on 2017/08/11 16:04:07 UTC

[GitHub] flink issue #4485: [FLINK-7378][core]Implement the FixedBufferPool for float...

Github user zhijiangW commented on the issue:

    https://github.com/apache/flink/pull/4485
  
    @NicoK , Thank you for reviews!
    
    Considering the difference between `FixedBufferPool` and `LocalBufferPool`, I think you are right. I also think of this question when implement this new type. Maybe I misunderstood the stephan's meaning from google doc.
    
    I proposed the new `BufferPoolListener` for interaction easily between `RemoteInputChannel` and `BufferPool`, because `RemoteInputChannel` may request more floating buffers and wants to be notified more than once, and the boolean return can decide the behavior easily. And it can replace the current `EventListener` provided in `BufferProvider` interface. In order not to affect the current process, I did not replace that in this PR.
    
    I referred to the existing code format when implementation and found many cases keep the space after <p>. Thank you for letting me know the new rule. I may modify it next week based on your comments.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---