fix code

apache · Nov 15, 2024 · 82e6f6a · 82e6f6a
1 parent d4c86e3
commit 82e6f6a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/AbstractJdbcSinkWriter.java b/...main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/AbstractJdbcSinkWriter.java
@@ -100,6 +100,10 @@ protected void processSchemaChangeEvent(AlterTableColumnEvent event) throws IOEx
                             columns.stream()
                                     .filter(column -> afterColumn.equals(column.getName()))
                                     .findFirst();
+                    if (!columnOptional.isPresent()) {
+                        columns.add(addColumn);
+                        break;
+                    }
                     columnOptional.ifPresent(
                             column -> {
                                 int index = columns.indexOf(column);