You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by kh...@apache.org on 2021/07/10 10:54:24 UTC
[incubator-pinot] branch master updated: Provide HTTP client to
kinesis builder (#7148)
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 <kh...@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-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org