Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4656
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r139931718
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtilTest.java
---
@@
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r138965647
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -171,8
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r138837100
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -171,8
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r138836822
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtilTest.java
---
@@
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4656
[FLINK-7508][kinesis] switch FlinkKinesisProducer to use KPL's
ThreadingMode to ThreadedPool mode rather than Per_Request mode
## What is the purpose of the change
KinesisProducerLibrary
