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/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new b38fcee62c Bug fix: Do not ignore scheme property (#12332)
b38fcee62c is described below
commit b38fcee62cda17797dc1528f6b973908a18dab0b
Author: Kartik Khare <[email protected]>
AuthorDate: Wed Feb 14 11:44:42 2024 +0530
Bug fix: Do not ignore scheme property (#12332)
Co-authored-by: Kartik Khare
<[email protected]>
---
.../pinot/client/JsonAsyncHttpPinotClientTransportFactory.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/JsonAsyncHttpPinotClientTransportFactory.java
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/JsonAsyncHttpPinotClientTransportFactory.java
index 6f4e390599..3471796d28 100644
---
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/JsonAsyncHttpPinotClientTransportFactory.java
+++
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/JsonAsyncHttpPinotClientTransportFactory.java
@@ -85,8 +85,9 @@ public class JsonAsyncHttpPinotClientTransportFactory
implements PinotClientTran
_headers = ConnectionUtils.getHeadersFromProperties(properties);
}
- if (_scheme == null) {
- _scheme = properties.getProperty("scheme",
CommonConstants.HTTP_PROTOCOL);
+ String scheme = properties.getProperty("scheme",
CommonConstants.HTTP_PROTOCOL);
+ if (_scheme == null || !_scheme.contentEquals(scheme)) {
+ _scheme = scheme;
}
if (_sslContext == null &&
_scheme.contentEquals(CommonConstants.HTTPS_PROTOCOL)) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
