[hotfix] [kinesis] Add serialVersionUID to KinesisPartitioner

laubersder · Jan 12, 2018 · 5a318de · 5a318de
1 parent 30734d5
commit 5a318de
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...nesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java b/...nesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java
@@ -29,6 +29,8 @@
 @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