Skip to content

Commit 36ff32f

Browse files
committed
transaction mode use fixed
1 parent 1d81db7 commit 36ff32f

File tree

1 file changed

+1
-2
lines changed
  • data-loader/cli/src/main/java/com/scalar/db/dataloader/cli/command/dataimport

1 file changed

+1
-2
lines changed

data-loader/cli/src/main/java/com/scalar/db/dataloader/cli/command/dataimport/ImportCommand.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
import com.scalar.db.api.TableMetadata;
99
import com.scalar.db.dataloader.core.DataLoaderError;
1010
import com.scalar.db.dataloader.core.FileFormat;
11-
import com.scalar.db.dataloader.core.ScalarDbMode;
1211
import com.scalar.db.dataloader.core.dataimport.ImportManager;
1312
import com.scalar.db.dataloader.core.dataimport.ImportOptions;
1413
import com.scalar.db.dataloader.core.dataimport.controlfile.ControlFile;
@@ -148,7 +147,7 @@ private ImportManager createImportManager(
148147
reader,
149148
importOptions,
150149
importProcessorFactory,
151-
ScalarDbMode.TRANSACTION,
150+
scalarDbMode,
152151
TransactionFactory.create(configFile).getTransactionManager());
153152
if (importOptions.getLogMode().equals(LogMode.SPLIT_BY_DATA_CHUNK)) {
154153
importManager.addListener(new SplitByDataChunkImportLogger(config, logWriterFactory));

0 commit comments

Comments
 (0)