Refactor MySQLBaseRowsBinlogEvent

apache · Aug 17, 2024 · 43d11b3 · 43d11b3
1 parent acdc118
commit 43d11b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...re/data/pipeline/mysql/ingest/incremental/client/netty/MySQLBinlogEventPacketDecoder.java b/...re/data/pipeline/mysql/ingest/incremental/client/netty/MySQLBinlogEventPacketDecoder.java
@@ -219,7 +219,7 @@ private MySQLDeleteRowsBinlogEvent decodeDeleteRowsEventV2(final MySQLBinlogEven
         MySQLBinlogRowsEventPacket packet = new MySQLBinlogRowsEventPacket(binlogEventHeader, payload);
         MySQLBinlogTableMapEventPacket tableMapEventPacket = binlogContext.getTableMapEvent(packet.getTableId());
         packet.readRows(tableMapEventPacket, payload);
-        MySQLDeleteRowsBinlogEvent result = new MySQLDeleteRowsBinlogEvent(tableMapEventPacket.getSchemaName(), tableMapEventPacket.getTableName(),  packet.getRows());
+        MySQLDeleteRowsBinlogEvent result = new MySQLDeleteRowsBinlogEvent(tableMapEventPacket.getSchemaName(), tableMapEventPacket.getTableName(), packet.getRows());
         initRowsEvent(result, binlogEventHeader);
         return result;
     }