Skip to content

Commit 0f03536

Browse files
committed
Changd put to mutate
1 parent f5bb662 commit 0f03536

File tree

1 file changed

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

1 file changed

+2
-1
lines changed

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/dao/ScalarDbDao.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import com.scalar.db.io.Key;
1919
import java.io.IOException;
2020
import java.util.ArrayList;
21+
import java.util.Collections;
2122
import java.util.List;
2223
import java.util.NoSuchElementException;
2324
import java.util.Optional;
@@ -107,7 +108,7 @@ public void put(
107108

108109
Put put = createPutWith(namespace, table, partitionKey, clusteringKey, columns);
109110
try {
110-
transaction.put(put);
111+
transaction.mutate(Collections.singletonList(put));
111112
} catch (CrudException e) {
112113
throw new ScalarDbDaoException(
113114
CoreError.DATA_LOADER_ERROR_CRUD_EXCEPTION.buildMessage(e.getMessage()), e);

0 commit comments

Comments
 (0)