eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/position/CanalCheckPositionMgr.java [71:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void prepareRecordPosition() {
        if (config.getStartPosition() != null && !config.getStartPosition().isEmpty()) {
            for (RecordPosition record : config.getStartPosition()) {
                CanalFullRecordOffset offset = (CanalFullRecordOffset) record.getRecordOffset();
                RdbSimpleTable table = new RdbSimpleTable(offset.getPosition().getSchema(), offset.getPosition().getTableName());
                positions.put(table, offset.getPosition());
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/position/CanalFullPositionMgr.java [72:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void prepareRecordPosition() {
        if (config.getStartPosition() != null && !config.getStartPosition().isEmpty()) {
            for (RecordPosition record : config.getStartPosition()) {
                CanalFullRecordOffset offset = (CanalFullRecordOffset) record.getRecordOffset();
                RdbSimpleTable table = new RdbSimpleTable(offset.getPosition().getSchema(), offset.getPosition().getTableName());
                positions.put(table, offset.getPosition());
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -