duplicated block id: 1 size: 46 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbSyncService.java (316:369) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseBatchSyncService.java (365:418) duplicated block id: 2 size: 40 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/ES6xAdapter.java (73:115) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/ES8xAdapter.java (68:110) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/ES7xAdapter.java (72:114) duplicated block id: 3 size: 32 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/SingleDml.java (68:101) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/SingleDml.java (68:101) duplicated block id: 4 size: 32 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (113:149) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (105:141) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (105:141) duplicated block id: 5 size: 27 cleaned lines of code in 2 files: - connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/producer/CanalPulsarMQProducer.java (171:204) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java (151:183) duplicated block id: 6 size: 26 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/SyncUtil.java (28:55) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/SyncUtil.java (28:55) duplicated block id: 7 size: 24 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (426:453) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (414:441) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (418:445) duplicated block id: 8 size: 21 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbSyncService.java (462:487) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseBatchSyncService.java (511:536) duplicated block id: 9 size: 21 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbMirrorDbSyncService.java (121:145) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseMirrorDbBatchSyncService.java (131:155) duplicated block id: 10 size: 20 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (319:344) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (309:334) duplicated block id: 11 size: 19 cleaned lines of code in 2 files: - client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/ExtensionLoader.java (219:247) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/ExtensionLoader.java (220:248) duplicated block id: 12 size: 19 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (248:272) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (239:263) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (239:263) duplicated block id: 13 size: 18 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java (279:299) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/ClickHouseAdapter.java (278:298) duplicated block id: 14 size: 17 cleaned lines of code in 3 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config/ConfigLoader.java (28:49) - client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/config/MappingConfigLoader.java (28:49) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config/ConfigLoader.java (30:51) duplicated block id: 15 size: 17 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (294:316) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (284:306) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (284:306) duplicated block id: 16 size: 17 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (455:475) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (443:463) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (447:467) duplicated block id: 17 size: 16 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (207:229) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (198:220) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (198:220) duplicated block id: 18 size: 15 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (185:204) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (176:195) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (176:195) duplicated block id: 19 size: 14 cleaned lines of code in 2 files: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (229:245) - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (193:209) duplicated block id: 20 size: 14 cleaned lines of code in 2 files: - client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/ExtensionLoader.java (73:89) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/ExtensionLoader.java (71:87) duplicated block id: 21 size: 14 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbSyncService.java (377:396) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseBatchSyncService.java (426:445) duplicated block id: 22 size: 14 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbMirrorDbSyncService.java (152:169) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseMirrorDbBatchSyncService.java (162:179) duplicated block id: 23 size: 14 cleaned lines of code in 2 files: - server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java (108:127) - deployer/src/main/java/com/alibaba/otter/canal/deployer/admin/CanalAdminController.java (85:104) duplicated block id: 24 size: 14 cleaned lines of code in 2 files: - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (163:179) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (184:200) duplicated block id: 25 size: 12 cleaned lines of code in 2 files: - parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java (164:179) - parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java (88:103) duplicated block id: 26 size: 12 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbEtlService.java (178:192) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseEtlService.java (182:196) duplicated block id: 27 size: 12 cleaned lines of code in 2 files: - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (266:281) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (266:281) duplicated block id: 28 size: 11 cleaned lines of code in 2 files: - filter/src/main/java/com/alibaba/otter/canal/filter/aviater/AviaterRegexFilter.java (42:59) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/filter/AviaterRegexFilter.java (40:57) duplicated block id: 29 size: 11 cleaned lines of code in 4 files: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (276:288) - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (275:287) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (193:205) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (214:226) duplicated block id: 30 size: 11 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (232:245) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (223:236) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (223:236) duplicated block id: 31 size: 11 cleaned lines of code in 2 files: - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ESConnection.java (158:170) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (165:177) duplicated block id: 32 size: 10 cleaned lines of code in 2 files: - filter/src/main/java/com/alibaba/otter/canal/filter/aviater/AviaterRegexFilter.java (61:74) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/filter/AviaterRegexFilter.java (59:72) duplicated block id: 33 size: 10 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/BatchExecutor.java (54:66) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/BatchExecutor.java (54:66) duplicated block id: 34 size: 10 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (337:348) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (392:403) duplicated block id: 35 size: 10 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (473:485) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ESConnection.java (186:198) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (197:209) duplicated block id: 36 size: 10 cleaned lines of code in 5 files: - example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientFlatMessageExample.java (71:83) - example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientExample.java (89:101) - example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java (73:85) - example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientExample.java (72:84) - example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaOffsetClientExample.java (80:92) duplicated block id: 37 size: 9 cleaned lines of code in 2 files: - filter/src/main/java/com/alibaba/otter/canal/filter/aviater/AviaterRegexFilter.java (109:119) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/filter/AviaterRegexFilter.java (107:117) duplicated block id: 38 size: 9 cleaned lines of code in 2 files: - common/src/main/java/com/alibaba/otter/canal/common/utils/PropertiesUtils.java (18:31) - deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java (463:476) duplicated block id: 39 size: 9 cleaned lines of code in 3 files: - client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/BatchExecutor.java (97:107) - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/BatchExecutor.java (85:95) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/BatchExecutor.java (102:112) duplicated block id: 40 size: 9 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config/MappingConfig.java (82:92) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config/MappingConfig.java (84:94) duplicated block id: 41 size: 9 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/BatchExecutor.java (35:45) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/BatchExecutor.java (35:45) duplicated block id: 42 size: 9 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (98:108) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (91:101) duplicated block id: 43 size: 8 cleaned lines of code in 2 files: - client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Dml.java (128:137) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/consumer/CommonMessage.java (108:117) duplicated block id: 44 size: 8 cleaned lines of code in 3 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config/MappingConfig.java (170:179) - client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/config/KuduMappingConfig.java (153:162) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config/MappingConfig.java (172:181) duplicated block id: 45 size: 8 cleaned lines of code in 2 files: - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/ES8xAdapter.java (55:65) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/ES7xAdapter.java (59:69) duplicated block id: 46 size: 8 cleaned lines of code in 2 files: - deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/SpringInstanceConfigMonitor.java (188:197) - deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerInstanceConfigMonitor.java (145:154) duplicated block id: 47 size: 7 cleaned lines of code in 4 files: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (291:299) - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (290:298) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (182:190) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (203:211) duplicated block id: 48 size: 7 cleaned lines of code in 6 files: - client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/TablestoreAdapter.java (343:351) - client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/PhoenixAdapter.java (317:325) - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java (332:340) - client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/KuduAdapter.java (234:242) - client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/HbaseAdapter.java (260:268) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/ClickHouseAdapter.java (331:339) duplicated block id: 49 size: 7 cleaned lines of code in 2 files: - client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/URLClassExtensionLoader.java (67:77) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/URLClassExtensionLoader.java (65:75) duplicated block id: 50 size: 7 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/SyncUtil.java (277:285) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/SyncUtil.java (261:269) duplicated block id: 51 size: 7 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/SyncUtil.java (287:296) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/SyncUtil.java (271:280) duplicated block id: 52 size: 7 cleaned lines of code in 2 files: - client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbSyncService.java (403:411) - client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseBatchSyncService.java (452:460) duplicated block id: 53 size: 7 cleaned lines of code in 3 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java (174:182) - client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java (165:173) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java (165:173) duplicated block id: 54 size: 7 cleaned lines of code in 2 files: - meta/src/main/java/com/alibaba/otter/canal/meta/MixedMetaManager.java (60:70) - meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java (94:104) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - common/src/main/java/com/alibaba/otter/canal/common/utils/PropertiesUtils.java (9:16) - deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java (454:461) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/connector/SimpleAdminConnector.java (305:312) - client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java (421:428) duplicated block id: 57 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (178:185) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (229:236) duplicated block id: 58 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (187:194) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (238:245) duplicated block id: 59 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (227:234) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (280:287) duplicated block id: 60 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (236:243) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (289:296) duplicated block id: 61 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (245:252) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (298:305) duplicated block id: 62 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (319:326) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (374:381) duplicated block id: 63 size: 6 cleaned lines of code in 2 files: - client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java (328:335) - client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java (383:390) duplicated block id: 64 size: 6 cleaned lines of code in 3 files: - meta/src/main/java/com/alibaba/otter/canal/meta/MixedMetaManager.java (93:100) - meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java (125:132) - meta/src/main/java/com/alibaba/otter/canal/meta/FileMixedMetaManager.java (144:151)