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/12 13:31:11 UTC
[19/19] flink git commit: [hotfix] [kafka] Add missing
serialVersionUIDs to all Kafka connector Serializable classes
[hotfix] [kafka] Add missing serialVersionUIDs to all Kafka connector Serializable classes
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ade8263
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4ade8263
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4ade8263
Branch: refs/heads/master
Commit: 4ade82631b43c28262c303c4ba028270652f4db3
Parents: 4ceabed
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
Authored: Fri Jan 12 17:33:12 2018 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Fri Jan 12 19:43:29 2018 +0800
----------------------------------------------------------------------
.../flink/streaming/connectors/kafka/FlinkKafka011Exception.java | 2 ++
.../connectors/kafka/partitioner/FlinkFixedPartitioner.java | 2 ++
.../streaming/util/serialization/JSONDeserializationSchema.java | 3 +++
.../util/serialization/JSONKeyValueDeserializationSchema.java | 3 +++
.../util/serialization/JsonRowDeserializationSchema.java | 2 ++
.../streaming/util/serialization/JsonRowSerializationSchema.java | 3 +++
6 files changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4ade8263/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java b/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
index 6189d8a..61b0ff6 100644
--- a/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
+++ b/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
@@ -26,6 +26,8 @@ import org.apache.flink.util.FlinkException;
@PublicEvolving
public class FlinkKafka011Exception extends FlinkException {
+ private static final long serialVersionUID = 920269130311214200L;
+
private final FlinkKafka011ErrorCode errorCode;
public FlinkKafka011Exception(FlinkKafka011ErrorCode errorCode, String message) {
http://git-wip-us.apache.org/repos/asf/flink/blob/4ade8263/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
index 906238d..6e83ddd 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
@@ -54,6 +54,8 @@ import org.apache.flink.util.Preconditions;
@PublicEvolving
public class FlinkFixedPartitioner<T> extends FlinkKafkaPartitioner<T> {
+ private static final long serialVersionUID = -3785320239953858777L;
+
private int parallelInstanceId;
@Override
http://git-wip-us.apache.org/repos/asf/flink/blob/4ade8263/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java
index 8c572c2..900c094 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONDeserializationSchema.java
@@ -32,6 +32,9 @@ import java.io.IOException;
*/
@PublicEvolving
public class JSONDeserializationSchema extends AbstractDeserializationSchema<ObjectNode> {
+
+ private static final long serialVersionUID = -1699854177598621044L;
+
private ObjectMapper mapper;
@Override
http://git-wip-us.apache.org/repos/asf/flink/blob/4ade8263/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java
index 0168eb7..caffcec 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java
@@ -40,6 +40,9 @@ import static org.apache.flink.api.java.typeutils.TypeExtractor.getForClass;
*/
@PublicEvolving
public class JSONKeyValueDeserializationSchema implements KeyedDeserializationSchema<ObjectNode> {
+
+ private static final long serialVersionUID = 1509391548173891955L;
+
private final boolean includeMetadata;
private ObjectMapper mapper;
http://git-wip-us.apache.org/repos/asf/flink/blob/4ade8263/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java
index 1f4a60e..21215cd 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowDeserializationSchema.java
@@ -41,6 +41,8 @@ import java.io.IOException;
@PublicEvolving
public class JsonRowDeserializationSchema implements DeserializationSchema<Row> {
+ private static final long serialVersionUID = -228294330688809195L;
+
/** Type information describing the result type. */
private final TypeInformation<Row> typeInfo;
http://git-wip-us.apache.org/repos/asf/flink/blob/4ade8263/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
index 3e72506..44ce7ea 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
@@ -40,6 +40,9 @@ import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.Obje
*/
@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. */