[hotfix] [kafka] Add missing serialVersionUIDs to all Kafka connector…

… Serializable classes
laubersder · Jan 12, 2018 · 4ade826 · 4ade826
1 parent 4ceabed
commit 4ade826
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 0 deletions.
diff --git a/....11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java b/....11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
@@ -26,6 +26,8 @@
 @PublicEvolving
 public class FlinkKafka011Exception extends FlinkException {
 
+ private static final long serialVersionUID = 920269130311214200L;
+
  private final FlinkKafka011ErrorCode errorCode;
 
  public FlinkKafka011Exception(FlinkKafka011ErrorCode errorCode, String message) {

diff --git a/...n/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java b/...n/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
@@ -54,6 +54,8 @@
 @PublicEvolving
 public class FlinkFixedPartitioner<T> extends FlinkKafkaPartitioner<T> {
 
+ private static final long serialVersionUID = -3785320239953858777L;
+
  private int parallelInstanceId;
 
  @Override

diff --git a/...rc/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java b/...rc/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java
@@ -32,6 +32,9 @@
  */
 @PublicEvolving
 public class JSONDeserializationSchema extends AbstractDeserializationSchema<ObjectNode> {
+
+ private static final long serialVersionUID = -1699854177598621044L;
+
  private ObjectMapper mapper;
 
  @Override

diff --git a/...java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java b/...java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java
@@ -40,6 +40,9 @@
  */
 @PublicEvolving
 public class JSONKeyValueDeserializationSchema implements KeyedDeserializationSchema<ObjectNode> {
+
+ private static final long serialVersionUID = 1509391548173891955L;
+
  private final boolean includeMetadata;
  private ObjectMapper mapper;
 

diff --git a/...main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java b/...main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java
@@ -41,6 +41,8 @@
 @PublicEvolving
 public class JsonRowDeserializationSchema implements DeserializationSchema<Row> {
 
+ private static final long serialVersionUID = -228294330688809195L;
+
  /** Type information describing the result type. */
  private final TypeInformation<Row> typeInfo;
 

diff --git a/...c/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java b/...c/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
@@ -40,6 +40,9 @@
  */
 @PublicEvolving
 public class JsonRowSerializationSchema implements SerializationSchema<Row> {
+
+ private static final long serialVersionUID = -2885556750743978636L;
+
  /** Fields names in the input Row object. */
  private final String[] fieldNames;
  /** Object mapper that is used to create output JSON objects. */