From 82e6f6a1f97538e18c0e5c7a232fbff97faa356b Mon Sep 17 00:00:00 2001
From: shiwanming <1633138551@qq.com>
Date: Tue, 12 Nov 2024 22:07:11 +0800
Subject: [PATCH] fix code

---
 .../seatunnel/jdbc/sink/AbstractJdbcSinkWriter.java           | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/AbstractJdbcSinkWriter.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/AbstractJdbcSinkWriter.java
index 0e15092f4d0..4d7a9ef2fdc 100644
--- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/AbstractJdbcSinkWriter.java
+++ b/seatunnel-connectors-v2/connector-jdbc/src/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);