chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed compiler failed

Browse Source
This commit is contained in:
七锋
2018-11-05 16:53:15 +08:00
parent 6ff57f53f8
commit 359aa1a074
2 changed files with 4 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dbsync/src/test/java/com/taobao/tddl/dbsync/binlog/BaseLogFetcherTest.java
View File

@@ -68,7 +68,7 @@ public class BaseLogFetcherTest {
// update需要处理before/after
System.out.println("-------> before");
parseOneRow(event, buffer, columns, false);
if (!buffer.nextOneRow(changeColumns)) {
if (!buffer.nextOneRow(changeColumns, true)) {
break;
}
System.out.println("-------> after");
@@ -97,7 +97,7 @@ public class BaseLogFetcherTest {
}
ColumnInfo info = columnInfo[i];
buffer.nextValue(info.type, info.meta);
buffer.nextValue(null , i ,info.type, info.meta);
if (buffer.isNull()) {
//