This is an automated email from the ASF dual-hosted git repository. kharekartik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push: new 52d733c Provide HTTP client to kinesis builder (#7148) 52d733c is described below commit 52d733ce6dac9aa6716cb5191bacf81e899a1f1f Author: Kartik Khare <kharekar...@gmail.com> AuthorDate: Sat Jul 10 16:24:05 2021 +0530 Provide HTTP client to kinesis builder (#7148) --- .../apache/pinot/plugin/stream/kinesis/KinesisConnectionHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConnectionHandler.java b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConnectionHandler.java index 2621ef0..dd7bf36 100644 --- a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConnectionHandler.java +++ b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConnectionHandler.java @@ -87,7 +87,8 @@ public class KinesisConnectionHandler { .httpClientBuilder(new ApacheSdkHttpService().createHttpClientBuilder()); } else { kinesisClientBuilder = - KinesisClient.builder().region(Region.of(_region)).credentialsProvider(DefaultCredentialsProvider.create()); + KinesisClient.builder().region(Region.of(_region)).credentialsProvider(DefaultCredentialsProvider.create()) + .httpClientBuilder(new ApacheSdkHttpService().createHttpClientBuilder()); } if (StringUtils.isNotBlank(_endpoint)) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org