@@ -330,7 +330,7 @@ public async Task<QueryHandle> StartQueryAsync(string statement, StartQueryOptio
330330 var timeout = _clusterOptions . TimeoutOptions . DispatchTimeout ;
331331 var httpClient = CreateHttpClient ( timeout ) ;
332332
333- var statusUri = Uri . TryCreate ( handle . Handle , UriKind . Absolute , out var absUri )
333+ var statusUri = Uri . TryCreate ( handle . Handle , UriKind . Absolute , out var absUri ) && ( absUri . Scheme == Uri . UriSchemeHttp || absUri . Scheme == Uri . UriSchemeHttps )
334334 ? absUri
335335 : new Uri ( _baseUri , handle . Handle ) ;
336336
@@ -405,7 +405,7 @@ public async Task<IQueryResult> FetchResultsAsync(string requestId, string handl
405405 var httpClient = CreateHttpClient ( timeout ) ;
406406 var deserializer = options . Deserializer ?? _clusterOptions . Deserializer ;
407407
408- var resultUri = Uri . TryCreate ( handlePath , UriKind . Absolute , out var absUri )
408+ var resultUri = Uri . TryCreate ( handlePath , UriKind . Absolute , out var absUri ) && ( absUri . Scheme == Uri . UriSchemeHttp || absUri . Scheme == Uri . UriSchemeHttps )
409409 ? absUri
410410 : new Uri ( _baseUri , handlePath ) ;
411411
@@ -453,7 +453,7 @@ public async Task DiscardResultsAsync(string requestId, string handlePath, Disca
453453 var timeout = _clusterOptions . TimeoutOptions . DispatchTimeout ;
454454 var httpClient = CreateHttpClient ( timeout ) ;
455455
456- var resultUri = Uri . TryCreate ( handlePath , UriKind . Absolute , out var absUri )
456+ var resultUri = Uri . TryCreate ( handlePath , UriKind . Absolute , out var absUri ) && ( absUri . Scheme == Uri . UriSchemeHttp || absUri . Scheme == Uri . UriSchemeHttps )
457457 ? absUri
458458 : new Uri ( _baseUri , handlePath ) ;
459459
0 commit comments