From c725d1453fd7df3183359b4e135af1c1fc821396 Mon Sep 17 00:00:00 2001 From: jamesagnew Date: Tue, 18 May 2021 09:22:29 -0400 Subject: [PATCH] Add logs --- .../ca/uhn/fhir/jpa/bulk/imprt/job/BulkImportFileWriter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/bulk/imprt/job/BulkImportFileWriter.java b/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/bulk/imprt/job/BulkImportFileWriter.java index 5f893474c26..df6c3065a44 100644 --- a/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/bulk/imprt/job/BulkImportFileWriter.java +++ b/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/bulk/imprt/job/BulkImportFileWriter.java @@ -26,6 +26,7 @@ import ca.uhn.fhir.jpa.bulk.export.job.BulkExportJobConfig; import ca.uhn.fhir.jpa.bulk.imprt.model.JobFileRowProcessingModeEnum; import ca.uhn.fhir.jpa.bulk.imprt.model.ParsedBulkImportRecord; import ca.uhn.fhir.jpa.partition.SystemRequestDetails; +import ca.uhn.fhir.util.StopWatch; import org.hl7.fhir.instance.model.api.IBaseResource; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -51,6 +52,7 @@ public class BulkImportFileWriter implements ItemWriter @Override public void write(List theItemLists) throws Exception { ourLog.info("Beginning bulk import write {} chunks Job[{}] FileIndex[{}]", theItemLists.size(), myJobUuid, myFileIndex); + StopWatch sw = new StopWatch(); for (ParsedBulkImportRecord nextItem : theItemLists) { @@ -69,6 +71,7 @@ public class BulkImportFileWriter implements ItemWriter } + ourLog.info("Completed bulk import write {} chunks Job[{}] FileIndex[{}] in {}", theItemLists.size(), myJobUuid, myFileIndex, sw); } }