[Improve][Connector] Replace printStackTrace with proper logging (apache#10176)

Co-authored-by: mengxp <mengxp@longjitech.com>
Co-authored-by: David Zollo <davidzollo365@gmail.com>
Co-authored-by: dy102 <132787602+dybyte@users.noreply.github.com>

Author: 4 people

seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/client/ActivemqClient.java

@@ -63,10 +63,11 @@ public ActivemqClient(ReadonlyConfig config) {
             log.info("connection created");
 
         } catch (Exception e) {
-            e.printStackTrace();
+            log.error("Error while creating AMQ client", e);
             throw new ActivemqConnectorException(
                     ActivemqConnectorErrorCode.CREATE_ACTIVEMQ_CLIENT_FAILED,
-                    "Error while create AMQ client ");
+                    "Error while create AMQ client ",
+                    e);
         }
     }
 

seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/reader/GraphQLWebSocket.java

@@ -98,8 +98,7 @@ public void onClosing(@NotNull WebSocket webSocket, int code, @NotNull String re
         @Override
         public void onFailure(
                 @NotNull WebSocket webSocket, @NotNull Throwable t, @Nullable Response response) {
-            log.error("WebSocket connection failed: " + t.getMessage());
-            t.printStackTrace();
+            log.error("WebSocket connection failed", t);
             scheduleReconnect();
         }
 
@@ -108,7 +107,8 @@ public void onMessage(@NotNull WebSocket webSocket, @NotNull String text) {
             try {
                 buffer.put(text);
             } catch (InterruptedException e) {
-                e.printStackTrace();
+                log.error("Failed to put message into buffer", e);
+                Thread.currentThread().interrupt();
             }
         }
 
@@ -139,7 +139,8 @@ private void scheduleReconnect() {
                                         Thread.sleep(RETRY_DELAY_MS);
                                         connect();
                                     } catch (InterruptedException e) {
-                                        e.printStackTrace();
+                                        log.error("Reconnection attempt interrupted", e);
+                                        Thread.currentThread().interrupt();
                                     }
                                 })
                         .start();

seatunnel-connectors-v2/connector-sls/src/main/java/org/apache/seatunnel/connectors/seatunnel/sls/sink/SlsSinkWriter.java

@@ -77,8 +77,7 @@ public void write(SeaTunnelRow element) throws IOException {
         try {
             this.client.PutLogs(plr);
         } catch (Throwable e) {
-            log.error("write logs failed", e);
-            e.printStackTrace();
+            log.error("Failed to write logs to SLS", e);
             throw new IOException(e);
         }
     }