We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7b52568 commit 89eb3d6Copy full SHA for 89eb3d6
parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java
@@ -42,8 +42,8 @@ public void testSimple() {
42
controller.setEventFilter(new AviaterRegexFilter("test\\..*"));
43
controller.setEventBlackFilter(new AviaterRegexFilter("canal_tsdb\\..*"));
44
controller.setParallel(true);
45
- controller.setParallelBufferSize(4096);
46
- controller.setParallelThreadSize(16);
+ controller.setParallelBufferSize(256);
+ controller.setParallelThreadSize(2);
47
controller.setIsGTIDMode(false);
48
controller.setEventSink(new AbstractCanalEventSinkTest<List<Entry>>() {
49
0 commit comments