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 2017/10/25 11:53:04 UTC
[3/3] flink git commit: [hotfix] [kinesis] Properly add
serialVersionUIDs to FlinkKinesisProducer classes
[hotfix] [kinesis] Properly add serialVersionUIDs to FlinkKinesisProducer classes
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/12b7fc11
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/12b7fc11
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/12b7fc11
Branch: refs/heads/master
Commit: 12b7fc1109f85561fdbdf93c4655a656b29e8f03
Parents: bf5ef62
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
Authored: Fri Oct 20 17:11:00 2017 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Wed Oct 25 18:53:14 2017 +0800
----------------------------------------------------------------------
.../connectors/kinesis/FlinkKinesisProducer.java | 2 ++
.../connectors/kinesis/FlinkKinesisProducerTest.java | 12 ++++++++++++
2 files changed, 14 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/12b7fc11/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
index 2f12e7f..28aa4b3 100644
--- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
+++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
@@ -54,6 +54,8 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
*/
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. */
http://git-wip-us.apache.org/repos/asf/flink/blob/12b7fc11/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java
index 970116a..2cd0c17 100644
--- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java
+++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java
@@ -279,6 +279,9 @@ public class FlinkKinesisProducerTest {
* 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 class FlinkKinesisProducerTest {
* 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 class FlinkKinesisProducerTest {
* 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 class FlinkKinesisProducerTest {
* 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";