You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2018/01/06 06:49:50 UTC
[8/9] flink git commit: [hotfix] [kafka] Add serialVersionUID to
FlinkKafkaProducer010
[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 <tz...@apache.org>
Authored: Mon Dec 18 20:38:32 2017 -0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
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.
*/