DBZ-3328 Fix test failures
This commit is contained in:
parent
4dcda868b5
commit
7dd980e505
@ -64,7 +64,7 @@ public class TransactionalBufferTest {
|
||||
private static final TableId TABLE_ID = new TableId(TestHelper.SERVER_NAME, "DEBEZIUM", "TEST");
|
||||
private static final String ROW_ID = "AAABCD871DFAA";
|
||||
private static final String OTHER_ROW_ID = "BAABCD871DFAA";
|
||||
private static final LogMinerDmlEntry DML_ENTRY = new LogMinerDmlEntryImpl(RowMapper.INSERT, Collections.emptyList(), Collections.emptyList());
|
||||
private static final LogMinerDmlEntry DML_ENTRY = LogMinerDmlEntryImpl.forInsert(Collections.emptyList());
|
||||
|
||||
private static final Configuration config = new Configuration() {
|
||||
@Override
|
||||
|
@ -11,7 +11,6 @@
|
||||
import java.math.BigInteger;
|
||||
import java.sql.Timestamp;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
|
||||
import org.junit.Before;
|
||||
@ -75,7 +74,7 @@ public void testValueHolders() throws Exception {
|
||||
List<LogMinerColumnValue> newValues = new ArrayList<>();
|
||||
newValues.add(column1);
|
||||
newValues.add(column2);
|
||||
LogMinerDmlEntryImpl dmlEntryExpected = new LogMinerDmlEntryImpl(RowMapper.INSERT, newValues, Collections.emptyList());
|
||||
LogMinerDmlEntry dmlEntryExpected = LogMinerDmlEntryImpl.forInsert(newValues);
|
||||
dmlEntryExpected.setTransactionId("transaction_id");
|
||||
dmlEntryExpected.setObjectName(TABLE_NAME);
|
||||
dmlEntryExpected.setObjectOwner(SCHEMA_NAME);
|
||||
|
Loading…
Reference in New Issue
Block a user