DBZ-8130 Preserve ordering of tables inside batch
Fixes [DBZ-8130]
This commit is contained in:
parent
835b073eb8
commit
3c109179c6
@ -9,7 +9,7 @@
|
|||||||
|
|
||||||
import java.sql.SQLException;
|
import java.sql.SQLException;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.HashMap;
|
import java.util.LinkedHashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
@ -65,8 +65,8 @@ public JdbcChangeEventSink(JdbcSinkConnectorConfig config, StatelessSession sess
|
|||||||
@Override
|
@Override
|
||||||
public void execute(Collection<SinkRecord> records) {
|
public void execute(Collection<SinkRecord> records) {
|
||||||
|
|
||||||
final Map<TableId, Buffer> updateBufferByTable = new HashMap<>();
|
final Map<TableId, Buffer> updateBufferByTable = new LinkedHashMap<>();
|
||||||
final Map<TableId, Buffer> deleteBufferByTable = new HashMap<>();
|
final Map<TableId, Buffer> deleteBufferByTable = new LinkedHashMap<>();
|
||||||
|
|
||||||
for (SinkRecord record : records) {
|
for (SinkRecord record : records) {
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user