Bug fix: Do not ignore scheme property (#12332)

Co-authored-by: Kartik Khare <[email protected]>
apache · Feb 14, 2024 · b38fcee · b38fcee
1 parent 04dd579
commit b38fcee
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...lient/src/main/java/org/apache/pinot/client/JsonAsyncHttpPinotClientTransportFactory.java b/...lient/src/main/java/org/apache/pinot/client/JsonAsyncHttpPinotClientTransportFactory.java
@@ -85,8 +85,9 @@ public JsonAsyncHttpPinotClientTransportFactory withConnectionProperties(Propert
       _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)) {