[GitHub] [flink] dannycranmer commented on a change in pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

2021-09-09 Thread GitBox
dannycranmer commented on a change in pull request #17189: URL: https://github.com/apache/flink/pull/17189#discussion_r705274129 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java

[GitHub] [flink] dannycranmer commented on a change in pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

2021-09-09 Thread GitBox
dannycranmer commented on a change in pull request #17189: URL: https://github.com/apache/flink/pull/17189#discussion_r705096592 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java

[GitHub] [flink] dannycranmer commented on a change in pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

2021-09-08 Thread GitBox
dannycranmer commented on a change in pull request #17189: URL: https://github.com/apache/flink/pull/17189#discussion_r704784987 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java