[jira] [Created] (FLINK-12986) Add alternative implementations for BoundedBlockingSubpartition to address stability issues

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12986) Add alternative implementations for BoundedBlockingSubpartition to address stability issues

Shang Yuanchun (Jira)
Stephan Ewen created FLINK-12986:
------------------------------------

             Summary: Add alternative implementations for BoundedBlockingSubpartition to address stability issues
                 Key: FLINK-12986
                 URL: https://issues.apache.org/jira/browse/FLINK-12986
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Network
    Affects Versions: 1.9.0
            Reporter: Stephan Ewen
            Assignee: Stephan Ewen
             Fix For: 1.9.0


As discussed on the parent issues, the first implementation (based on memory mapped files) caused some stability issues under memory pressure.

This issue tracks adding alternative implementations (as discussed on the parent issue)
* Eagerly write to file and read via memory mapping the file (mode {{FILE_MMAP}})
* Eagerly write to file and read from file (mode {{FILE}})
* The existing implementation will be retained as mode {{MMAP}}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)