Elke mapper heeft zijn eigen databaseverbinding nodig. Maak de databaseverbinding in mapper_init()
en sluit het in mapper_final()
. U moet de database apart van het mrjob-script maken. U moet eerst een aantal zeer eenvoudige mrjob-scripts proberen. Je bent er niet op de juiste manier aan begonnen. Werk de voorbeelden in de documentatie door.