Skip to content

Commit 2bb8ebb

Browse files
committed
[Fix][Connector-V2] Fix issue of out-of-order fields in cdc
1 parent b2bb2f8 commit 2bb8ebb

File tree

1 file changed

+1
-1
lines changed
  • seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/scan

1 file changed

+1
-1
lines changed

seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/scan/MySqlSnapshotSplitReadTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,7 @@ private void createDataEventsForTable(
223223
rows++;
224224
final Object[] row = new Object[columnArray.getGreatestColumnPosition()];
225225
for (int i = 0; i < columnArray.getColumns().length; i++) {
226-
Column actualColumn = table.columns().get(i);
226+
Column actualColumn = columnArray.getColumns()[i];
227227
row[columnArray.getColumns()[i].position() - 1] =
228228
readField(rs, i + 1, actualColumn, table);
229229
}

0 commit comments

Comments
 (0)