@@ -146,21 +146,21 @@ protected override void ValidateOptions()
146146 ? connectTimeoutMsValue
147147 : throw new ArgumentOutOfRangeException ( SparkParameters . ConnectTimeoutMilliseconds , connectTimeoutMs , $ "must be a value of 0 (infinite) or between 1 .. { int . MaxValue } . default is 30000 milliseconds.") ;
148148 }
149-
149+
150150 // Parse retry configuration parameters
151151 Properties . TryGetValue ( SparkParameters . TemporarilyUnavailableRetry , out string ? tempUnavailableRetryStr ) ;
152152 int tempUnavailableRetryValue = 1 ; // Default to enabled
153153 if ( tempUnavailableRetryStr != null && ! int . TryParse ( tempUnavailableRetryStr , out tempUnavailableRetryValue ) )
154154 {
155- throw new ArgumentOutOfRangeException ( SparkParameters . TemporarilyUnavailableRetry , tempUnavailableRetryStr ,
155+ throw new ArgumentOutOfRangeException ( SparkParameters . TemporarilyUnavailableRetry , tempUnavailableRetryStr ,
156156 $ "must be a value of 0 (disabled) or 1 (enabled). Default is 1.") ;
157157 }
158158 TemporarilyUnavailableRetry = tempUnavailableRetryValue != 0 ;
159-
159+
160160 Properties . TryGetValue ( SparkParameters . TemporarilyUnavailableRetryTimeout , out string ? tempUnavailableRetryTimeoutStr ) ;
161161 if ( tempUnavailableRetryTimeoutStr != null )
162162 {
163- if ( ! int . TryParse ( tempUnavailableRetryTimeoutStr , NumberStyles . Integer , CultureInfo . InvariantCulture , out int tempUnavailableRetryTimeoutValue ) ||
163+ if ( ! int . TryParse ( tempUnavailableRetryTimeoutStr , NumberStyles . Integer , CultureInfo . InvariantCulture , out int tempUnavailableRetryTimeoutValue ) ||
164164 tempUnavailableRetryTimeoutValue < 0 )
165165 {
166166 throw new ArgumentOutOfRangeException ( SparkParameters . TemporarilyUnavailableRetryTimeout , tempUnavailableRetryTimeoutStr ,
@@ -172,7 +172,7 @@ protected override void ValidateOptions()
172172 {
173173 TemporarilyUnavailableRetryTimeout = 900 ; // Default to 15 minutes
174174 }
175-
175+
176176 TlsOptions = HiveServer2TlsImpl . GetHttpTlsOptions ( Properties ) ;
177177 }
178178
@@ -199,13 +199,13 @@ protected override TTransport CreateTransport()
199199 AuthenticationHeaderValue ? authenticationHeaderValue = GetAuthenticationHeaderValue ( authTypeValue , token , username , password , access_token ) ;
200200
201201 HttpClientHandler httpClientHandler = HiveServer2TlsImpl . NewHttpClientHandler ( TlsOptions ) ;
202-
202+
203203 // Create a RetryHttpHandler that wraps the HttpClientHandler to handle 503 responses
204204 var retryHandler = new RetryHttpHandler (
205- httpClientHandler ,
206- TemporarilyUnavailableRetry ,
205+ httpClientHandler ,
206+ TemporarilyUnavailableRetry ,
207207 TemporarilyUnavailableRetryTimeout ) ;
208-
208+
209209 HttpClient httpClient = new ( retryHandler ) ;
210210 httpClient . BaseAddress = baseAddress ;
211211 httpClient . DefaultRequestHeaders . Authorization = authenticationHeaderValue ;
0 commit comments