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:06 UTC
[14/19] flink git commit: [hotfix] [kinesis] Add serialVersionUID to
KinesisPartitioner
[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 <tz...@apache.org>
Authored: Fri Jan 12 16:57:38 2018 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@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