[
https://issues.apache.org/jira/browse/FLINK-1104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1104.
-----------------------------------
Resolution: Fixed
Assignee: Márton Balassi
Resolved in the following commit:
https://github.com/apache/incubator-flink/commit/7cc24006a992d67cd3de54b867b38161f5b08d92
> Eliminate Tuple1 from flink-streaming-connectors
> ------------------------------------------------
>
> Key: FLINK-1104
> URL: https://issues.apache.org/jira/browse/FLINK-1104
> Project: Flink
> Issue Type: Task
> Components: Streaming
> Reporter: Márton Balassi
> Assignee: Márton Balassi
> Priority: Minor
>
> The streaming connectors contains unnecessary usage of Tuple1. E.g. in
> KafkaSource:
> @Override
> public Tuple1<String> deserialize(byte[] msg) {
> String s = new String(msg);
> if(s.equals("q")){
> closeWithoutSend();
> }
> return new Tuple1<String>(s);
> }
> Please adjust the underlying interfaces and update the documentation
> accordingly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
