Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5069
---
Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5069#discussion_r153841399
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -41,7 +42,6 @
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5069#discussion_r153139738
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -41,7 +42,6
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5069#discussion_r153139774
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -18,14 +18,
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/5069
[FLINK-8149][kinesis] Replace usages of deprecated SerializationSchema
## What is the purpose of the change
The deprecated `SerializationSchema` in `flink-streaming-java`, has been
moved to `flin
