This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.3.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.3.1 by this push:
new 9219c2c0e format code in AbstractHttpClient (#3880)
9219c2c0e is described below
commit 9219c2c0ef08e9d0d0186f419b623ed7091045e4
Author: GuoPhilipse <[email protected]>
AuthorDate: Thu Nov 24 20:20:14 2022 +0800
format code in AbstractHttpClient (#3880)
---
.../org/apache/linkis/httpclient/AbstractHttpClient.scala | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/AbstractHttpClient.scala
b/linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/AbstractHttpClient.scala
index dbebaac03..2722807be 100644
---
a/linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/AbstractHttpClient.scala
+++
b/linkis-commons/linkis-httpclient/src/main/scala/org/apache/linkis/httpclient/AbstractHttpClient.scala
@@ -44,7 +44,7 @@ import org.apache.linkis.httpclient.response._
import org.apache.commons.io.IOUtils
import org.apache.commons.lang3.StringUtils
import org.apache.http.{HttpResponse, _}
-import org.apache.http.client.{CookieStore, ResponseHandler}
+import org.apache.http.client.CookieStore
import org.apache.http.client.config.RequestConfig
import org.apache.http.client.entity.{
DeflateDecompressingEntity,
@@ -422,7 +422,7 @@ abstract class AbstractHttpClient(clientConfig:
ClientConfig, clientName: String
} catch {
case connectionPoolTimeOutException: ConnectionPoolTimeoutException =>
val serverUrl = getServerUrl(req.getURI)
- addUnHealThyUrlToDiscovery(serverUrl)
+ addUnHealthyUrlToDiscovery(serverUrl)
logger.warn("will be server url add unhealthy for
connectionPoolTimeOutException")
throw new HttpClientRetryException(
"connectionPoolTimeOutException",
@@ -430,7 +430,7 @@ abstract class AbstractHttpClient(clientConfig:
ClientConfig, clientName: String
)
case connectionTimeOutException: ConnectTimeoutException =>
val serverUrl = getServerUrl(req.getURI)
- addUnHealThyUrlToDiscovery(serverUrl)
+ addUnHealthyUrlToDiscovery(serverUrl)
logger.warn("will be server url add unhealthy for
connectionTimeOutException")
throw new HttpClientRetryException(
"connectionTimeOutException",
@@ -438,7 +438,7 @@ abstract class AbstractHttpClient(clientConfig:
ClientConfig, clientName: String
)
case httpHostConnectException: HttpHostConnectException =>
val serverUrl = getServerUrl(req.getURI)
- addUnHealThyUrlToDiscovery(serverUrl)
+ addUnHealthyUrlToDiscovery(serverUrl)
logger.warn("will be server url add unhealthy for
httpHostConnectException")
throw new HttpClientRetryException("httpHostConnectException",
httpHostConnectException)
case t: Throwable =>
@@ -447,7 +447,7 @@ abstract class AbstractHttpClient(clientConfig:
ClientConfig, clientName: String
response
}
- private def addUnHealThyUrlToDiscovery(serverUrl: String): Unit = {
+ private def addUnHealthyUrlToDiscovery(serverUrl: String): Unit = {
discovery.foreach {
case d: AbstractDiscovery =>
d.addUnhealthyServerInstances(serverUrl)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
