[hotfix] [kafka] Add serialVersionUID to FlinkKafkaProducer010
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f462f771 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f462f771 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f462f771 Branch: refs/heads/release-1.4 Commit: f462f77194b76139591d478c4b66ef0676449849 Parents: 16a49de Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Mon Dec 18 20:38:32 2017 -0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri Jan 5 22:04:05 2018 -0800 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaProducer010.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f462f771/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java b/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java index 369ab89..e721340 100644 --- a/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java +++ b/flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java @@ -41,6 +41,8 @@ import java.util.Properties; */ public class FlinkKafkaProducer010<T> extends FlinkKafkaProducer09<T> { + private static final long serialVersionUID = 1L; + /** * Flag controlling whether we are writing the Flink record's timestamp into Kafka. */
