[seatunnel] branch dev updated: [Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)

[ty...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0eff3aeed [Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)
0eff3aeed is described below

commit 0eff3aeed0b0654284d767d3122ea63d8bd0e7ac
Author: ic4y <83...@users.noreply.github.com>
AuthorDate: Wed May 24 22:49:08 2023 +0800

    [Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)
---
 .../connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java
index 329a87d47..78e881439 100644
--- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java
+++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java
@@ -244,7 +244,7 @@ public class JdbcOutputFormatBuilder {
             SeaTunnelRow newRow = new SeaTunnelRow(fields);
             newRow.setTableId(row.getTableId());
             newRow.setRowKind(row.getRowKind());
-            return row;
+            return newRow;
         };
     }
 }