This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 295d08b4 [CodeStyle] remove unnecessary semicolon (#1883)
295d08b4 is described below
commit 295d08b4f69e6dbf255bf7058c6e26603c7b55f1
Author: legendtkl <[email protected]>
AuthorDate: Sun May 15 14:49:17 2022 +0800
[CodeStyle] remove unnecessary semicolon (#1883)
---
.../apache/seatunnel/flink/http/source/util/HttpClientUtils.java | 6 +++---
.../apache/seatunnel/spark/http/source/util/HttpClientUtils.java | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientUtils.java
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientUtils.java
index da31a62a..8fe9b62c 100644
---
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientUtils.java
+++
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-http/src/main/java/org/apache/seatunnel/flink/http/source/util/HttpClientUtils.java
@@ -162,7 +162,7 @@ public class HttpClientUtils {
// Encapsulate request parameters
packageParam(params, httpPost);
- try (CloseableHttpClient httpClient = HttpClients.createDefault();) {
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
// Execute the request and get the response result
return getHttpClientResult(httpClient, httpPost);
}
@@ -195,7 +195,7 @@ public class HttpClientUtils {
packageParam(params, httpPut);
- try (CloseableHttpClient httpClient = HttpClients.createDefault();) {
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
return getHttpClientResult(httpClient, httpPut);
}
}
@@ -213,7 +213,7 @@ public class HttpClientUtils {
HttpDelete httpDelete = new HttpDelete(url);
RequestConfig requestConfig =
RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
httpDelete.setConfig(requestConfig);
- try (CloseableHttpClient httpClient = HttpClients.createDefault();) {
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
return getHttpClientResult(httpClient, httpDelete);
}
}
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientUtils.java
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientUtils.java
index 8dd3c6bd..0eb810bf 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientUtils.java
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/src/main/java/org/apache/seatunnel/spark/http/source/util/HttpClientUtils.java
@@ -159,7 +159,7 @@ public class HttpClientUtils {
// Encapsulate request parameters
packageParam(params, httpPost);
- try (CloseableHttpClient httpClient = HttpClients.createDefault();) {
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
// Execute the request and get the response result
return getHttpClientResult(httpClient, httpPost);
}
@@ -192,7 +192,7 @@ public class HttpClientUtils {
packageParam(params, httpPut);
- try (CloseableHttpClient httpClient = HttpClients.createDefault();) {
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
return getHttpClientResult(httpClient, httpPut);
}
}
@@ -209,7 +209,7 @@ public class HttpClientUtils {
HttpDelete httpDelete = new HttpDelete(url);
RequestConfig requestConfig =
RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
httpDelete.setConfig(requestConfig);
- try (CloseableHttpClient httpClient = HttpClients.createDefault();) {
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
return getHttpClientResult(httpClient, httpDelete);
}
}