[ https://issues.apache.org/jira/browse/FLINK-18680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-18680. ---------------------------------- Assignee: Stephan Ewen (was: Jiangjie Qin) Resolution: Fixed Fixed in 1.12 via f42a3ebc3e81a034b7221a803c153636fef34903 > Improve RecordsWithSplitIds API > ------------------------------- > > Key: FLINK-18680 > URL: https://issues.apache.org/jira/browse/FLINK-18680 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Common > Affects Versions: 1.11.1 > Reporter: Jiangjie Qin > Assignee: Stephan Ewen > Priority: Major > Fix For: 1.12.0 > > > The current API requires some improvements in a few aspects: > # The current API enforces the {{SplitReaders}} to expose the records via a > java collection which is not performance friendly in some cases. > # Some information does not change across the records, but the current > RecordsWithSplitIds data structure does not support per-batch information. -- This message was sent by Atlassian Jira (v8.3.4#803005)