(seatunnel) branch dev updated: [Improve][Elasticsearch] Truncate the exception message body for request errors (#8263)

[lidongdai]

This is an automated email from the ASF dual-hosted git repository.

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b9d850e61c [Improve][Elasticsearch] Truncate the exception message 
body for request errors (#8263)
b9d850e61c is described below

commit b9d850e61c43855ad3e55d1271ea181621ce82ad
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Mon Dec 16 22:03:22 2024 +0800

    [Improve][Elasticsearch] Truncate the exception message body for request 
errors (#8263)
---
 .../seatunnel/elasticsearch/client/EsRestClient.java        | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java
index b54541bf93..279d480e92 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java
@@ -225,13 +225,16 @@ public class EsRestClient implements Closeable {
                 throw new ElasticsearchConnectorException(
                         ElasticsearchConnectorErrorCode.BULK_RESPONSE_ERROR,
                         String.format(
-                                "bulk es response status code=%d,request 
boy=%s",
-                                response.getStatusLine().getStatusCode(), 
requestBody));
+                                "bulk es response status=%s,request 
body(truncate)=%s",
+                                response,
+                                requestBody.substring(0, Math.min(1000, 
requestBody.length()))));
             }
         } catch (IOException e) {
             throw new ElasticsearchConnectorException(
                     ElasticsearchConnectorErrorCode.BULK_RESPONSE_ERROR,
-                    String.format("bulk es error,request boy=%s", requestBody),
+                    String.format(
+                            "bulk es error,request body(truncate)=%s",
+                            requestBody.substring(0, Math.min(1000, 
requestBody.length()))),
                     e);
         }
     }
@@ -332,13 +335,13 @@ public class EsRestClient implements Closeable {
                 throw new ElasticsearchConnectorException(
                         ElasticsearchConnectorErrorCode.SCROLL_REQUEST_ERROR,
                         String.format(
-                                "POST %s response status code=%d,request 
boy=%s",
+                                "POST %s response status code=%d,request 
body=%s",
                                 endpoint, 
response.getStatusLine().getStatusCode(), requestBody));
             }
         } catch (IOException e) {
             throw new ElasticsearchConnectorException(
                     ElasticsearchConnectorErrorCode.SCROLL_REQUEST_ERROR,
-                    String.format("POST %s error,request boy=%s", endpoint, 
requestBody),
+                    String.format("POST %s error,request body=%s", endpoint, 
requestBody),
                     e);
         }
     }