Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4871#discussion_r146466653
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -207,23 +214,8 @@ public void invoke(OUT value) throws Exception {
if (this.producer == null) {
throw new RuntimeException("Kinesis producer has been
closed");
}
- if (thrownException != null) {
--- End diff --
Will keep that in mind for the future :+1:
---
