[ https://issues.apache.org/jira/browse/FLINK-3979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-3979. --------------------------------- Resolution: Fixed Fix Version/s: 1.1.0 Fixed via ad52a5f0cebe6e5d593be0ae40656b28470af106 Thank you for the contribution! > [documentation]add missed import classes in run_example_quickstart > ------------------------------------------------------------------ > > Key: FLINK-3979 > URL: https://issues.apache.org/jira/browse/FLINK-3979 > Project: Flink > Issue Type: Improvement > Components: Documentation > Reporter: Jia Zhai > Fix For: 1.1.0 > > > The classes that need to be imported for this part of code > {code} > result > .map(new MapFunction<Tuple2<String,Long>, String>() { > @Override > public String map(Tuple2<String, Long> tuple) { > return tuple.toString(); > } > }) > .addSink(new FlinkKafkaProducer08<>("localhost:9092", "wiki-result", new > SimpleStringSchema())); > {code} > is > {code} > import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer08; > import org.apache.flink.streaming.util.serialization.SimpleStringSchema; > import org.apache.flink.api.common.functions.MapFunction; > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)