fix code

apache · Nov 28, 2024 · 7ab43fd · 7ab43fd
1 parent 5d2fabe
commit 7ab43fd
Showing 1 changed file with 5 additions and 15 deletions.
diff --git a/...in/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java b/...in/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java
@@ -92,25 +92,15 @@ public void applySchemaChange(SchemaChangeEvent event) {
             throw new RuntimeException("Failed to load MySQL JDBC driver", e);
         }
 
-        Connection conn = null;
-        try {
-            conn =
-                    DriverManager.getConnection(
-                            sinkConfig.getJdbcUrl(),
-                            sinkConfig.getUsername(),
-                            sinkConfig.getPassword());
+        try (Connection conn =
+                DriverManager.getConnection(
+                        sinkConfig.getJdbcUrl(),
+                        sinkConfig.getUsername(),
+                        sinkConfig.getPassword())) {
             SchemaUtils.applySchemaChange(event, conn, sinkTablePath);
         } catch (SQLException e) {
             throw new CatalogException(
                     String.format("Failed connecting to %s via JDBC.", sinkConfig.getJdbcUrl()), e);
-        } finally {
-            if (conn != null) {
-                try {
-                    conn.close();
-                } catch (SQLException e) {
-                    log.error("Failed to close JDBC connection", e);
-                }
-            }
         }
     }