From 1f8851b90603ceefef0aea3a3db3980a300722bd Mon Sep 17 00:00:00 2001
From: iceblue510 <67048891+iceblue510@users.noreply.github.com>
Date: Mon, 6 Jul 2020 17:57:30 +0800
Subject: [PATCH] modify sqlTask (#3152)

---
 .../dolphinscheduler/server/worker/task/sql/SqlTask.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
index c30ca23ca..5511c6acd 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java
@@ -364,7 +364,7 @@ public class SqlTask extends AbstractTask {
                        Connection connection){
         if (resultSet != null){
             try {
-                connection.close();
+                resultSet.close();
             } catch (SQLException e) {
 
             }
@@ -372,7 +372,7 @@ public class SqlTask extends AbstractTask {
 
         if (pstmt != null){
             try {
-                connection.close();
+                pstmt.close();
             } catch (SQLException e) {
 
             }
-- 
GitLab