This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.5
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
new e173c373a [Improve] using bug fixed.
e173c373a is described below
commit e173c373af9c593060625952d9811f6c7b8e2f1a
Author: benjobs <[email protected]>
AuthorDate: Fri Aug 9 13:12:25 2024 +0800
[Improve] using bug fixed.
---
.../src/main/scala/org/apache/streampark/common/util/Utils.scala | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala
b/streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala
index 3e35c388b..2015a2c80 100644
---
a/streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala
+++
b/streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala
@@ -125,7 +125,12 @@ object Utils extends Logger {
try {
func(handle)
} catch {
- case e: Throwable if excFunc != null => excFunc(e)
+ case e: Throwable =>
+ if (excFunc != null) {
+ excFunc(e)
+ } else {
+ throw e
+ }
} finally {
if (handle != null) {
handle.close()
