flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzuli...@apache.org
Subject [14/19] flink git commit: [hotfix] [kinesis] Add serialVersionUID to KinesisPartitioner
Date Fri, 12 Jan 2018 13:31:06 GMT
[hotfix] [kinesis] Add serialVersionUID to KinesisPartitioner


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5a318de9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5a318de9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5a318de9

Branch: refs/heads/master
Commit: 5a318de97734df52dcc641c0594ead9df18b5e2f
Parents: 30734d5
Author: Tzu-Li (Gordon) Tai <tzulitai@apache.org>
Authored: Fri Jan 12 16:57:38 2018 +0800
Committer: Tzu-Li (Gordon) Tai <tzulitai@apache.org>
Committed: Fri Jan 12 19:43:28 2018 +0800

----------------------------------------------------------------------
 .../flink/streaming/connectors/kinesis/KinesisPartitioner.java     | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/5a318de9/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java
b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java
index 6082346..70528dc 100644
--- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java
+++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java
@@ -29,6 +29,8 @@ import java.io.Serializable;
 @PublicEvolving
 public abstract class KinesisPartitioner<T> implements Serializable {
 
+	private static final long serialVersionUID = -7467294664702189780L;
+
 	/**
 	 * Return a partition id based on the input.
 	 * @param element Element to partition


Mime
View raw message