flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhijiangW <...@git.apache.org>
Subject [GitHub] flink issue #4559: [FLINK-7468][network] Implement sender backlog logic for ...
Date Thu, 14 Dec 2017 09:38:54 GMT
Github user zhijiangW commented on the issue:

    @NicoK, I have submitted two `[hotfix]` commits for the above issues.
    One is for `Nullable` annotation and tests of backlog statistics. And the other is for
updating backlog in thread-safe.  
    For updating backlog, I think it should be done in `PipelinedSubpartition` and `SpillableSubpartition`
separately in order to under synchronized region, although it seems somewhat redundant.  But
I notice that the `isReleased()` method in `ResultSubpartition` is also implemented in this


View raw message