@@ -146,21 +146,21 @@ protected override void ValidateOptions()
146
146
? connectTimeoutMsValue
147
147
: throw new ArgumentOutOfRangeException ( SparkParameters . ConnectTimeoutMilliseconds , connectTimeoutMs , $ "must be a value of 0 (infinite) or between 1 .. { int . MaxValue } . default is 30000 milliseconds.") ;
148
148
}
149
-
149
+
150
150
// Parse retry configuration parameters
151
151
Properties . TryGetValue ( SparkParameters . TemporarilyUnavailableRetry , out string ? tempUnavailableRetryStr ) ;
152
152
int tempUnavailableRetryValue = 1 ; // Default to enabled
153
153
if ( tempUnavailableRetryStr != null && ! int . TryParse ( tempUnavailableRetryStr , out tempUnavailableRetryValue ) )
154
154
{
155
- throw new ArgumentOutOfRangeException ( SparkParameters . TemporarilyUnavailableRetry , tempUnavailableRetryStr ,
155
+ throw new ArgumentOutOfRangeException ( SparkParameters . TemporarilyUnavailableRetry , tempUnavailableRetryStr ,
156
156
$ "must be a value of 0 (disabled) or 1 (enabled). Default is 1.") ;
157
157
}
158
158
TemporarilyUnavailableRetry = tempUnavailableRetryValue != 0 ;
159
-
159
+
160
160
Properties . TryGetValue ( SparkParameters . TemporarilyUnavailableRetryTimeout , out string ? tempUnavailableRetryTimeoutStr ) ;
161
161
if ( tempUnavailableRetryTimeoutStr != null )
162
162
{
163
- if ( ! int . TryParse ( tempUnavailableRetryTimeoutStr , NumberStyles . Integer , CultureInfo . InvariantCulture , out int tempUnavailableRetryTimeoutValue ) ||
163
+ if ( ! int . TryParse ( tempUnavailableRetryTimeoutStr , NumberStyles . Integer , CultureInfo . InvariantCulture , out int tempUnavailableRetryTimeoutValue ) ||
164
164
tempUnavailableRetryTimeoutValue < 0 )
165
165
{
166
166
throw new ArgumentOutOfRangeException ( SparkParameters . TemporarilyUnavailableRetryTimeout , tempUnavailableRetryTimeoutStr ,
@@ -172,7 +172,7 @@ protected override void ValidateOptions()
172
172
{
173
173
TemporarilyUnavailableRetryTimeout = 900 ; // Default to 15 minutes
174
174
}
175
-
175
+
176
176
TlsOptions = HiveServer2TlsImpl . GetHttpTlsOptions ( Properties ) ;
177
177
}
178
178
@@ -199,13 +199,13 @@ protected override TTransport CreateTransport()
199
199
AuthenticationHeaderValue ? authenticationHeaderValue = GetAuthenticationHeaderValue ( authTypeValue , token , username , password , access_token ) ;
200
200
201
201
HttpClientHandler httpClientHandler = HiveServer2TlsImpl . NewHttpClientHandler ( TlsOptions ) ;
202
-
202
+
203
203
// Create a RetryHttpHandler that wraps the HttpClientHandler to handle 503 responses
204
204
var retryHandler = new RetryHttpHandler (
205
- httpClientHandler ,
206
- TemporarilyUnavailableRetry ,
205
+ httpClientHandler ,
206
+ TemporarilyUnavailableRetry ,
207
207
TemporarilyUnavailableRetryTimeout ) ;
208
-
208
+
209
209
HttpClient httpClient = new ( retryHandler ) ;
210
210
httpClient . BaseAddress = baseAddress ;
211
211
httpClient . DefaultRequestHeaders . Authorization = authenticationHeaderValue ;
0 commit comments