Github user tzulitai commented on the pull request:
https://github.com/apache/flink/commit/547d19f9196512231661f427f3792f2e1f831339#commitcomment-27231640
In
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableKinesisDataFetcher.java:
In
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableKinesisDataFetcher.java
on line 107:
Yes, that is correct. Will fix.---
