Skip to content

Commit 75ad22a

Browse files
committed
Update GdsParallelBatchImporter
1 parent 8facbd9 commit 75ad22a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

io/core/src/main/java/org/neo4j/gds/core/io/db/GdsParallelBatchImporter.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@
4444
import org.neo4j.kernel.impl.index.schema.DefaultIndexProvidersAccess;
4545
import org.neo4j.kernel.impl.index.schema.IndexImporterFactoryImpl;
4646
import org.neo4j.kernel.impl.scheduler.JobSchedulerFactory;
47+
import org.neo4j.kernel.impl.transaction.log.files.LogTailMetadataFactoryImpl;
4748
import org.neo4j.kernel.impl.transaction.log.files.TransactionLogInitializer;
4849
import org.neo4j.kernel.lifecycle.LifeSupport;
4950
import org.neo4j.logging.internal.LogService;
@@ -250,6 +251,7 @@ private BatchImporter instantiateBatchImporter(
250251
return storageEngineFactory.batchImporter(
251252
databaseLayout,
252253
this.fileSystem,
254+
false, // overrideExistingDatabase
253255
PageCacheTracer.NULL,
254256
importConfig,
255257
logService,
@@ -264,6 +266,8 @@ private BatchImporter instantiateBatchImporter(
264266
new IndexImporterFactoryImpl(),
265267
EmptyMemoryTracker.INSTANCE,
266268
CursorContextFactory.NULL_CONTEXT_FACTORY,
269+
1,
270+
new LogTailMetadataFactoryImpl(this.fileSystem),
267271
indexProvidersAccess
268272
);
269273
}

0 commit comments

Comments
 (0)