flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1505) Separate buffer reader and channel consumption logic
Date Tue, 10 Feb 2015 09:04:35 GMT
Ufuk Celebi created FLINK-1505:

             Summary: Separate buffer reader and channel consumption logic
                 Key: FLINK-1505
                 URL: https://issues.apache.org/jira/browse/FLINK-1505
             Project: Flink
          Issue Type: Improvement
          Components: Distributed Runtime
    Affects Versions: master
            Reporter: Ufuk Celebi
            Priority: Minor

Currently, the hierarchy of readers (f.a.o.runtime.io.network.api) is bloated. There is no
separation between consumption of the input channels and the buffer readers.

This was not the case up until release-0.8 and has been introduced by me with intermediate
results. I think this was a mistake and we should seperate this again. flink-streaming is
currently the heaviest user of these lower level APIs and I have received feedback from [~gyfora]
to undo this as well.

This message was sent by Atlassian JIRA

View raw message