[hotfix] [kinesis] Properly add serialVersionUIDs to FlinkKinesisProd…

…ucer classes
laubersder · Oct 25, 2017 · 12b7fc1 · 12b7fc1
1 parent bf5ef62
commit 12b7fc1
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/...sis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java b/...sis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
@@ -54,6 +54,8 @@
  */
 public class FlinkKinesisProducer<OUT> extends RichSinkFunction<OUT> implements CheckpointedFunction {
 
+ private static final long serialVersionUID = 6447077318449477846L;
+
  private static final Logger LOG = LoggerFactory.getLogger(FlinkKinesisProducer.class);
 
  /** Properties to parametrize settings such as AWS service region, access key etc. */

diff --git a/...src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java b/...src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java
@@ -279,6 +279,9 @@ public void go() throws Exception {
  * to the enclosing class, which is not serializable) used for testing.
  */
  private final class NonSerializableSerializationSchema implements KinesisSerializationSchema<String> {
+
+ private static final long serialVersionUID = 3361337188490178780L;
+
  @Override
  public ByteBuffer serialize(String element) {
  return ByteBuffer.wrap(element.getBytes());
@@ -294,6 +297,9 @@ public String getTargetStream(String element) {
  * A static, serializable {@link KinesisSerializationSchema}.
  */
  private static final class SerializableSerializationSchema implements KinesisSerializationSchema<String> {
+
+ private static final long serialVersionUID = 6298573834520052886L;
+
  @Override
  public ByteBuffer serialize(String element) {
  return ByteBuffer.wrap(element.getBytes());
@@ -310,6 +316,9 @@ public String getTargetStream(String element) {
  * to the enclosing class, which is not serializable) used for testing.
  */
  private final class NonSerializableCustomPartitioner extends KinesisPartitioner<String> {
+
+ private static final long serialVersionUID = -5961578876056779161L;
+
  @Override
  public String getPartitionId(String element) {
  return "test-partition";
@@ -320,6 +329,9 @@ public String getPartitionId(String element) {
  * A static, serializable {@link KinesisPartitioner}.
  */
  private static final class SerializableCustomPartitioner extends KinesisPartitioner<String> {
+
+ private static final long serialVersionUID = -4996071893997035695L;
+
  @Override
  public String getPartitionId(String element) {
  return "test-partition";