From ea6311ad9fc31f8b5eeb574de539ae61cd991a9e Mon Sep 17 00:00:00 2001 From: pn-koshikawa Date: Tue, 30 Jan 2024 06:53:22 +0000 Subject: [PATCH] update comment --- .../marketo/delegate/ProgramMembersBulkExtractInputPlugin.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/org/embulk/input/marketo/delegate/ProgramMembersBulkExtractInputPlugin.java b/src/main/java/org/embulk/input/marketo/delegate/ProgramMembersBulkExtractInputPlugin.java index c377f6e..cb6f98b 100644 --- a/src/main/java/org/embulk/input/marketo/delegate/ProgramMembersBulkExtractInputPlugin.java +++ b/src/main/java/org/embulk/input/marketo/delegate/ProgramMembersBulkExtractInputPlugin.java @@ -215,6 +215,7 @@ private Future createFutureTask(PluginTask task, RecordImporter recordImporte while (csvRecords.hasNext()) { Map csvRecord = csvRecords.next(); ObjectNode objectNode = MarketoUtils.OBJECT_MAPPER.valueToTree(csvRecord); + // MEMO: pageBuilderがスレッドアンセーフなために排他制御を利用する synchronized (pageBuilderLock) { recordImporter.importRecord(new AllStringJacksonServiceRecord(objectNode), pageBuilder); }