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

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


The following commit(s) were added to refs/heads/dev by this push:
     new a64cbf6bc delete unuse e.printexception. (#4236)
a64cbf6bc is described below

commit a64cbf6bcac8ec0fca997fcc28ceed35d394ae97
Author: ouyangwulin <[email protected]>
AuthorDate: Sun Apr 27 20:07:40 2025 +0800

    delete unuse e.printexception. (#4236)
---
 .../org/apache/streampark/flink/client/impl/YarnSessionClient.scala   | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
index 003e80ed9..bb2348cf1 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
@@ -165,13 +165,11 @@ object YarnSessionClient extends YarnClientTrait {
     } catch {
       case e: Exception =>
         logError(s"start flink session fail in ${deployRequest.deployMode} 
mode")
-        e.printStackTrace()
         throw e
     } finally {
       Utils.close(client, clusterDescriptor)
     }
   }
-
   def shutdown(shutDownRequest: ShutDownRequest): ShutDownResponse = {
     var clusterDescriptor: YarnClusterDescriptor = null
     var client: ClusterClient[ApplicationId] = null
@@ -203,11 +201,9 @@ object YarnSessionClient extends YarnClientTrait {
     } catch {
       case e: Exception =>
         logError(s"shutdown flink session fail in 
${shutDownRequest.deployMode} mode")
-        e.printStackTrace()
         throw e
     } finally {
       Utils.close(client, clusterDescriptor)
     }
   }
-
 }

Reply via email to