[hotfix] [kafka] Fix stale Javadoc link in FlinkKafkaProducer09 The previous link was referencing a non-existent constructor signature.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16a49de3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16a49de3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/16a49de3 Branch: refs/heads/release-1.4 Commit: 16a49de3f66e29108f6fb8977a51a2652ed3f312 Parents: 24d4493 Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Mon Dec 18 20:36:31 2017 -0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri Jan 5 22:03:58 2018 -0800 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaProducer09.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/16a49de3/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer09.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer09.java b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer09.java index 19f445f..7f00c92 100644 --- a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer09.java +++ b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer09.java @@ -219,7 +219,7 @@ public class FlinkKafkaProducer09<IN> extends FlinkKafkaProducerBase<IN> { * * @deprecated This is a deprecated constructor that does not correctly handle partitioning when * producing to multiple topics. Use - * {@link #FlinkKafkaProducer09(String, org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema, Properties, FlinkKafkaPartitioner)} instead. + * {@link #FlinkKafkaProducer09(String, KeyedSerializationSchema, Properties, FlinkKafkaPartitioner)} instead. */ @Deprecated public FlinkKafkaProducer09(String topicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, KafkaPartitioner<IN> customPartitioner) {
