Skip to content

Commit a64cbf6

Browse files
authored
delete unuse e.printexception. (#4236)
1 parent d4bde44 commit a64cbf6

1 file changed

Lines changed: 0 additions & 4 deletions

File tree

streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -165,13 +165,11 @@ object YarnSessionClient extends YarnClientTrait {
165165
} catch {
166166
case e: Exception =>
167167
logError(s"start flink session fail in ${deployRequest.deployMode} mode")
168-
e.printStackTrace()
169168
throw e
170169
} finally {
171170
Utils.close(client, clusterDescriptor)
172171
}
173172
}
174-
175173
def shutdown(shutDownRequest: ShutDownRequest): ShutDownResponse = {
176174
var clusterDescriptor: YarnClusterDescriptor = null
177175
var client: ClusterClient[ApplicationId] = null
@@ -203,11 +201,9 @@ object YarnSessionClient extends YarnClientTrait {
203201
} catch {
204202
case e: Exception =>
205203
logError(s"shutdown flink session fail in ${shutDownRequest.deployMode} mode")
206-
e.printStackTrace()
207204
throw e
208205
} finally {
209206
Utils.close(client, clusterDescriptor)
210207
}
211208
}
212-
213209
}

0 commit comments

Comments
 (0)